| /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> { impl
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() argument
59 Parent->completeTask(); in operator() argument
64 TaskQueue *Parent; argument
86 Task<Callable> T{std::move(C), *this}; in async() argument
|
| /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
47 Task& operator=(const Task&) = delete; argument
51 Task& operator=(Task&& other); argument
54 void SetHeapHandle(const HeapHandle& handle) {} in SetHeapHandle()
57 void ClearHeapHandle() {} in ClearHeapHandle()
60 HeapHandle GetHeapHandle() const { return HeapHandle::Invalid(); } in GetHeapHandle()
|
| D | task.cc | 20 Task::Task(const Location& posted_from, in Task() function in base::internal::Task
31 Task::Task(const Location& posted_from, in Task() function in base::internal::Task
54 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() argument
226 using TasksById = absl::flat_hash_map<int64_t, std::shared_ptr<Task>>; argument
|
| /external/rust/crates/async-task/src/ |
| D | task.rs | 47 pub struct Task<T> { struct
55 unsafe impl<T: Send> Send for Task<T> {} argument
56 unsafe impl<T> Sync for Task<T> {} implementation
58 impl<T> Unpin for Task<T> {} implementation
61 impl<T> std::panic::UnwindSafe for Task<T> {} implementation
63 impl<T> std::panic::RefUnwindSafe for Task<T> {} implementation
65 impl<T> Task<T> { implementation
414 impl<T> Drop for Task<T> { implementation
421 impl<T> Future for Task<T> { implementation
432 impl<T> fmt::Debug for Task<T> { 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/swiftshader/third_party/marl/include/marl/ |
| D | task.h | 64 Task::Task() {} in Task() function
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/rust/crates/tokio/src/runtime/task/ |
| D | mod.rs | 219 pub(crate) struct Task<S: 'static> { struct
220 raw: RawTask, argument
224 unsafe impl<S> Send for Task<S> {} implementation
225 unsafe impl<S> Sync for Task<S> {} implementation
335 impl<S: 'static> Task<S> { impl
365 impl<S: 'static> Task<S> { impl
380 impl<S: Schedule> Task<S> { implementation
441 impl<S: 'static> Drop for Task<S> { implementation
461 impl<S> fmt::Debug for Task<S> { implementation
476 unsafe impl<S> linked_list::Link for Task<S> { implementation
|
| /external/rust/crates/tokio/tests/ |
| D | io_driver.rs | 16 struct Task<T> { struct
20 impl<T: Send> ArcWake for Task<T> { implementation
26 impl<T> Task<T> { impl
|
| /external/crosvm/tools/impl/ |
| D | presubmit.py | 152 class Task(object): class
237 def print_logs(tasks: List[Task]):
256 def print_summary(tasks: List[Task]):
266 def execute_tasks_parallel(tasks: List[Task]):
303 def execute_tasks_serial(tasks: List[Task]):
|
| /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/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/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 | 34 Task() : native_type_(*this) {} in Task() function
37 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/rust/crates/futures-executor/src/ |
| D | thread_pool.rs | 300 struct Task { struct
307 mutex: UnparkMutex<Task>, argument
311 impl Task { implementation
344 impl fmt::Debug for Task { implementation
|
| /external/ims/rcs/rcsservice/src/com/android/service/ims/ |
| D | Task.java | 37 public class Task{ class
67 public Task(int taskId, int cmdId, ContactCapabilityResponse listener) { in Task() method in Task
|
| /external/ruy/ruy/ |
| D | thread_pool.h | 30 struct Task { struct
31 virtual ~Task() {} in ~Task() argument
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | ThreadEnvironment.h | 16 struct Task { struct
17 std::function<void()> f;
|
| /external/vogar/src/vogar/tasks/ |
| D | Task.java | 30 public abstract class Task { class
37 protected Task(String name) { in Task() method in Task
|