| /external/rust/crates/futures-util/src/stream/futures_unordered/ |
| D | task.rs | 10 pub(super) struct Task<Fut> { struct
16 pub(super) next_all: AtomicPtr<Task<Fut>>, argument
19 pub(super) prev_all: UnsafeCell<*const Task<Fut>>, argument
27 pub(super) next_ready_to_run: AtomicPtr<Task<Fut>>, argument
41 // `Task` can be sent across threads safely because it ensures that argument
46 unsafe impl<Fut> Send for Task<Fut> {} implementation
47 unsafe impl<Fut> Sync for Task<Fut> {} implementation
49 impl<Fut> ArcWake for Task<Fut> { implementation
78 impl<Fut> Task<Fut> { implementation
109 impl<Fut> Drop for Task<Fut> { implementation
|
| /external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/ |
| D | TaskQueue.h | 40 template <typename Callable> struct Task { struct
42 explicit Task(Callable C, TaskQueue &Parent) in Task() function
59 Parent->completeTask(); in operator() argument
64 TaskQueue *Parent; argument
86 Task<Callable> T{std::move(C), *this}; in async() argument
|
| /external/swiftshader/third_party/llvm-16.0/llvm/include/llvm/Support/ |
| D | TaskQueue.h | 40 template <typename Callable> struct Task { struct
42 explicit Task(Callable C, TaskQueue &Parent) in Task() argument
59 Parent->completeTask(); in operator() argument
64 TaskQueue *Parent; argument
86 Task<Callable> T{std::move(C), *this}; in async() argument
|
| D | ThreadPool.h | 67 auto Task = in async() local
75 auto Task = in async() local
121 createTaskAndFuture(std::function<ResTy()> Task) { in createTaskAndFuture()
130 createTaskAndFuture(std::function<void()> Task) { in createTaskAndFuture()
148 std::shared_future<ResTy> asyncImpl(std::function<ResTy()> Task, in asyncImpl()
|
| /external/libchrome/base/task_scheduler/ |
| D | task.h | 24 struct BASE_EXPORT Task : public PendingTask { struct
41 Task& operator=(Task&& other); argument
44 TaskTraits traits; argument
59 // Sequence -> Task -> TaskRunner -> Sequence -> ... argument
64 scoped_refptr<SequencedTaskRunner> sequenced_task_runner_ref; argument
65 scoped_refptr<SingleThreadTaskRunner> single_thread_task_runner_ref; argument
|
| D | task.cc | 21 Task::Task(const Location& posted_from, in Task() function in base::internal::Task
52 Task::Task(Task&& other) noexcept in Task() function in base::internal::Task
|
| /external/cronet/base/task/thread_pool/ |
| D | task.h | 23 struct BASE_EXPORT Task : public PendingTask { struct
50 Task& operator=(const Task&) = delete; argument
54 Task& operator=(Task&& other); argument
57 void SetHeapHandle(const HeapHandle& handle) {} in SetHeapHandle()
60 void ClearHeapHandle() {} in ClearHeapHandle()
63 HeapHandle GetHeapHandle() const { return HeapHandle::Invalid(); } in GetHeapHandle()
|
| D | task.cc | 12 Task::Task(const Location& posted_from, in Task() function in base::internal::Task
26 Task::Task(const Location& posted_from, in Task() function in base::internal::Task
42 Task::Task(const TaskMetadata& metadata, OnceClosure task) in Task() function in base::internal::Task
47 Task::Task(Task&& other) noexcept : PendingTask(std::move(other)) {} in Task() function in base::internal::Task
|
| /external/cronet/base/task/sequence_manager/ |
| D | tasks.h | 102 struct BASE_EXPORT Task : public PendingTask { struct
111 Task& operator=(Task&& other); argument
127 TaskOrder task_order() const; argument
135 TaskType task_type; argument
139 scoped_refptr<SequencedTaskRunner> task_runner; argument
158 bool WillRunTask(); argument
173 WeakPtr<internal::DelayedTaskHandleDelegate> delayed_task_handle_delegate_; argument
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | worker_impl.h | 89 struct Task { struct
90 explicit Task(TaskDef task_def) : task_def(std::move(task_def)) {} in Task() function
92 TaskDef task_def; argument
96 std::unique_ptr<TaskRunner> task_runner; argument
106 Status EnsureTaskInitialized(Task& task); argument
|
| D | dispatcher_state.h | 203 struct Task { struct
205 explicit Task(const T& create_task_update, in Task() function
226 using TasksById = absl::flat_hash_map<int64_t, std::shared_ptr<Task>>; argument
|
| /external/rust/crates/async-task/src/ |
| D | task.rs | 49 pub struct Task<T, M = ()> { struct
57 unsafe impl<T: Send, M: Send + Sync> Send for Task<T, M> {} argument
58 unsafe impl<T, M: Send + Sync> Sync for Task<T, M> {} implementation
60 impl<T, M> Unpin for Task<T, M> {} implementation
63 impl<T, M> std::panic::UnwindSafe for Task<T, M> {} implementation
65 impl<T, M> std::panic::RefUnwindSafe for Task<T, M> {} implementation
67 impl<T, M> Task<T, M> { impl
440 impl<T, M> Drop for Task<T, M> { implementation
447 impl<T, M> Future for Task<T, M> { implementation
458 impl<T, M: fmt::Debug> fmt::Debug for Task<T, M> { implementation
|
| /external/swiftshader/src/Vulkan/ |
| D | VkQueue.hpp | 65 struct Task struct in vk::Queue
67 uint32_t submitCount = 0;
68 SubmitInfo *pSubmits = nullptr;
69 std::shared_ptr<sw::CountedEvent> events;
71 enum Type
76 Type type = SUBMIT_QUEUE;
|
| /external/rust/crates/tokio/tests/ |
| D | io_driver.rs | 16 struct Task<T> { struct
20 impl<T: Send> ArcWake for Task<T> { argument
26 impl<T> Task<T> { implementation
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | mod.rs | 218 pub(crate) struct Task<S: 'static> { struct
219 raw: RawTask, argument
223 unsafe impl<S> Send for Task<S> {} argument
224 unsafe impl<S> Sync for Task<S> {} implementation
334 impl<S: 'static> Task<S> { impl
386 impl<S: Schedule> Task<S> { impl
447 impl<S: 'static> Drop for Task<S> { implementation
467 impl<S> fmt::Debug for Task<S> { implementation
482 unsafe impl<S> linked_list::Link for Task<S> { implementation
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | task.h | 65 Task::Task(const Task& o) : function(o.function), flags(o.flags) {} in Task() function
66 Task::Task(Task&& o) : function(std::move(o.function)), flags(o.flags) {} in Task() function
67 Task::Task(const Function& function_, Flags flags_ /* = Flags::None */) in Task() function
69 Task::Task(Function&& function_, Flags flags_ /* = Flags::None */) in Task() function
|
| /external/crosvm/tools/impl/ |
| D | presubmit.py | 150 class Task(object): class
253 def print_logs(tasks: List[Task]):
272 def print_summary(tasks: List[Task]):
282 def execute_tasks_parallel(tasks: List[Task]):
319 def execute_tasks_serial(tasks: List[Task]):
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
| D | ThreadPool.cpp | 34 PackagedTaskTy Task; in ThreadPool() local
81 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
125 auto Task = std::move(Tasks.front()); in wait() local
131 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
|
| /external/llvm/lib/Support/ |
| D | ThreadPool.cpp | 34 PackagedTaskTy Task; in ThreadPool() local
85 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
129 auto Task = std::move(Tasks.front()); in wait() local
139 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | dump.rs | 27 pub struct Task { struct
40 pub(crate) fn new(tasks: Vec<Task>) -> Self { in new() argument
59 impl Task { impl
|
| /external/grpc-grpc/test/core/event_engine/fuzzing_event_engine/ |
| D | fuzzing_event_engine.h | 133 struct Task { struct
134 Task(intptr_t id, absl::AnyInvocable<void()> closure) in Task() argument
136 intptr_t id;
137 absl::AnyInvocable<void()> closure;
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | multiplex_router.cc | 280 struct MultiplexRouter::Task { struct in mojo::internal::MultiplexRouter
283 static std::unique_ptr<Task> CreateMessageTask( in CreateMessageTask()
289 static std::unique_ptr<Task> CreateNotifyErrorTask( in CreateNotifyErrorTask()
296 ~Task() {} in ~Task()
298 bool IsMessageTask() const { return type == MESSAGE; } in IsMessageTask()
299 bool IsNotifyErrorTask() const { return type == NOTIFY_ERROR; } in IsNotifyErrorTask()
301 MessageWrapper message_wrapper;
302 scoped_refptr<InterfaceEndpoint> endpoint_to_notify;
304 enum Type { MESSAGE, NOTIFY_ERROR };
305 Type type;
[all …]
|
| /external/pigweed/pw_async/public/pw_async/ |
| D | task.h | 35 Task() : native_type_(*this) {} in Task() function
38 explicit Task(TaskFunction&& f) : native_type_(*this, std::move(f)) {} in Task() function
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/LTO/ |
| D | Caching.cpp | 35 return [=](unsigned Task, StringRef Key) -> AddStreamFn { in localCache()
76 unsigned Task; in localCache() member
133 return [=](size_t Task) -> std::unique_ptr<NativeObjectStream> { in localCache()
|
| /external/ruy/ruy/ |
| D | thread_pool.h | 30 struct Task { struct
31 virtual ~Task() {} in ~Task() argument
|