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
73 impl Task { implementation
84 impl Task { impl
85 pub(crate) unsafe fn from_raw(ptr: NonNull<Header>) -> Task { in from_raw()
94 ) -> (Task, JoinHandle<T::Output>) in create_task()
132 impl Drop for Task { implementation
|
| D | task_handle.rs | 227 fn to_task(&self) -> Task { in to_task()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | timer_test.rs | 36 struct Task {} struct
38 impl Task { implementation
62 async fn execute(&self, task: Task) { in execute()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | queue.rs | 68 pub(crate) fn pop_front(&self) -> Option<Task> { in pop_front()
73 pub(crate) fn push_back(&self, task: Task, global: &GlobalQueue) { in push_back()
78 pub(crate) fn steal_into(&self, dst: &LocalQueue) -> Option<Task> { in steal_into()
194 pub(crate) fn pop_front(&self) -> Option<Task> { in pop_front()
260 pub(crate) fn push_back(&self, mut task: Task, global: &GlobalQueue) { in push_back()
291 task: Task, in push_overflowed()
294 ) -> Result<(), Task> { in push_overflowed() argument
334 pub(crate) fn steal_into(&self, dst: &LocalQueue) -> Option<Task> { in steal_into()
436 pub(super) fn push_batch(&self, tasks: Vec<UnsafeCell<MaybeUninit<Task>>>, task: Task) { in push_batch()
454 ) -> Option<Task> { in pop_batch()
[all …]
|
| D | mod.rs | 52 fn schedule(&self, task: Task, lifo: bool); in schedule()
58 fn schedule(&self, _task: Task, _lifo: bool) { in schedule()
|
| D | current_thread.rs | 46 fn schedule(&self, task: Task, _lifo: bool) { in schedule()
55 fn pop(&self) -> Option<Task> { in pop()
|
| D | async_pool.rs | 59 fn schedule(&self, task: Task, lifo: bool) { in schedule()
153 pub(crate) fn enqueue(&self, mut task: Task, lifo: bool) -> bool { in enqueue()
189 pub(crate) fn dequeue(&self, index: usize, worker_inner: &mut worker::Inner) -> Option<Task> { in dequeue()
|
| D | worker.rs | 171 fn get_task(&self, inner: &mut Inner, worker_ctx: &WorkerContext) -> Option<Task> { in get_task()
|
| D | blocking_pool.rs | 166 type Task = task::Task; typedef
|
| /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 | 26 pub(crate) fn ffrt_submit(t: Task, builder: &TaskBuilder) { in ffrt_submit()
|