Searched defs:Task (Results 1 – 11 of 11) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | mod.rs | 68 pub(crate) struct Task(pub(crate) RawTask); struct
70 unsafe impl Send for Task {} implementation
71 unsafe impl Sync for Task {} implementation
74 impl Task { implementation
91 pub(crate) unsafe fn from_raw(ptr: NonNull<Header>) -> Task { in from_raw()
96 impl Task { implementation
102 ) -> (Task, JoinHandle<T::Output>) in create_task()
|
| D | task_handle.rs | 255 fn to_task(&self) -> Task { in to_task()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | queue.rs | 78 pub(crate) fn pop_front(&self) -> Option<Task> { in pop_front()
83 pub(crate) fn push_back(&self, task: Task, global: &GlobalQueue) { in push_back()
88 pub(crate) fn steal_into(&self, dst: &LocalQueue) -> Option<Task> { in steal_into()
204 pub(crate) fn pop_front(&self) -> Option<Task> { in pop_front()
267 pub(crate) fn push_back(&self, mut task: Task, global: &GlobalQueue) { in push_back()
298 task: Task, in push_overflowed()
301 ) -> Result<(), Task> { in push_overflowed() argument
341 pub(crate) fn steal_into(&self, dst: &LocalQueue) -> Option<Task> { in steal_into()
457 pub(super) fn push_batch(&self, tasks: Vec<UnsafeCell<MaybeUninit<Task>>>, task: Task) { in push_batch()
475 ) -> Option<Task> { in pop_batch()
[all …]
|
| D | async_pool.rs | 60 fn schedule(&self, task: Task, lifo: bool) { in schedule()
182 fn enqueue_under_ctx(&self, mut task: Task, worker_ctx: &WorkerContext, lifo: bool) -> bool { in enqueue_under_ctx()
214 pub(crate) fn enqueue(&self, task: Task, lifo: bool) -> bool { in enqueue()
229 fn get_task_from_queues(&self, worker_inner: &mut worker::Inner) -> Option<Task> { in get_task_from_queues()
264 fn get_task_from_searching(&self, worker_inner: &mut worker::Inner) -> Option<Task> { in get_task_from_searching()
295 ) -> Option<Task> { in dequeue()
312 fn steal(&self, destination: &LocalQueue) -> Option<Task> { in steal()
694 ) -> (Task, JoinHandle<T::Output>) in create_task()
|
| D | mod.rs | 51 fn schedule(&self, task: Task, lifo: bool); in schedule()
57 fn schedule(&self, _task: Task, _lifo: bool) { in schedule()
|
| D | current_thread.rs | 59 fn schedule(&self, task: Task, _lifo: bool) { in schedule()
73 fn pop(&self) -> Option<Task> { in pop()
|
| D | blocking_pool.rs | 166 type Task = task::Task; typedef
207 fn spawn(&self, task: Task) { in spawn()
|
| D | worker.rs | 162 fn get_task(&self, inner: &mut Inner, worker_ctx: &WorkerContext) -> Option<Task> { in get_task()
|
| /commonlibrary/c_utils/base/include/ |
| D | thread_pool.h | 38 typedef std::function<void()> Task; typedef
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ffrt/ |
| D | spawner.rs | 25 pub(crate) fn ffrt_submit(t: Task, builder: &TaskBuilder) { in ffrt_submit()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task.h | 109 …Task(napi_env env, TaskType taskType, const char* name) : env_(env), taskType_(taskType), name_(na… in Task() function
|