| /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
36 // `Task` can be sent across threads safely because it ensures that argument
41 unsafe impl<Fut> Send for Task<Fut> {} implementation
42 unsafe impl<Fut> Sync for Task<Fut> {} implementation
44 impl<Fut> ArcWake for Task<Fut> { implementation
71 impl<Fut> Task<Fut> { impl
102 impl<Fut> Drop for Task<Fut> { implementation
|
| /external/llvm-project/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/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/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> { impl
356 impl<T> Drop for Task<T> { implementation
363 impl<T> Future for Task<T> { implementation
374 impl<T> fmt::Debug for Task<T> { implementation
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | worker_impl.h | 60 struct Task { struct
61 explicit Task(TaskDef task_def) : task_def(std::move(task_def)) {} in Task() function
63 TaskDef task_def; argument
66 std::unique_ptr<TaskRunner> task_runner; argument
74 Status EnsureTaskInitialized(Task& task); argument
|
| D | dispatcher_state.h | 151 struct Task { struct
152 explicit Task(int64 task_id, const std::shared_ptr<Job>& job, in Task() argument
160 const int64 task_id;
161 const std::shared_ptr<Job> job;
162 const std::string worker_address;
163 const std::string transfer_address;
164 int64 starting_round = 0;
165 bool finished = false;
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | mod.rs | 38 pub(crate) struct Task<S: 'static> { struct
39 raw: RawTask, argument
43 unsafe impl<S> Send for Task<S> {} argument
44 unsafe impl<S> Sync for Task<S> {} implementation
122 impl<S: 'static> Task<S> { impl
146 impl<S: 'static> Task<S> { impl
161 impl<S: Schedule> Task<S> { implementation
181 impl<S: 'static> Drop for Task<S> { implementation
191 impl<S> fmt::Debug for Task<S> { implementation
206 unsafe impl<S> linked_list::Link for Task<S> { implementation
|
| /external/llvm-project/clang/test/AST/ |
| D | coroutine-locals-cleanup.cpp | 7 struct Task { struct
9 Task get_return_object() noexcept { in get_return_object() argument
53 Task(handle_t coro) noexcept : coro_(coro) {} in Task() argument
57 Task(const Task &t) = delete; argument
|
| /external/llvm-project/clang/test/CodeGenCoroutines/ |
| D | coro-symmetric-transfer-02.cpp | 7 struct Task { struct
9 Task get_return_object() noexcept { in get_return_object() argument
53 Task(handle_t coro) noexcept : coro_(coro) {} in Task() argument
57 Task(const Task &t) = delete; argument
|
| /external/swiftshader/src/Vulkan/ |
| D | VkQueue.hpp | 64 struct Task struct in vk::Queue
66 uint32_t submitCount = 0;
67 VkSubmitInfo *pSubmits = nullptr;
68 std::shared_ptr<sw::CountedEvent> events;
70 enum Type
75 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/tests/ |
| D | io_driver.rs | 15 struct Task<T> { struct
19 impl<T: Send> ArcWake for Task<T> { argument
25 impl<T> Task<T> { implementation
|
| /external/llvm-project/clang-tools-extra/clangd/index/ |
| D | Background.h | 72 struct Task { struct
73 explicit Task(std::function<void()> Run) : Run(std::move(Run)) {} in Task() argument
80 bool operator<(const Task &O) const { return QueuePri < O.QueuePri; } argument
|
| /external/llvm-project/llvm/lib/Support/ |
| D | ThreadPool.cpp | 32 PackagedTaskTy Task; in ThreadPool() local
75 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
117 auto Task = std::move(Tasks.front()); in wait() local
123 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/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-project/clang-tools-extra/clangd/unittests/support/ |
| D | CancellationTests.cpp | 16 auto Task = cancelableTask(); in TEST() local
26 auto Task = cancelableTask(); in TEST() local
36 auto Task = cancelableTask(); in TEST() local
80 auto Task = cancelableTask(); in TEST() local
|
| /external/llvm-project/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/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/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/ruy/ruy/ |
| D | thread_pool.h | 30 struct Task { struct
31 virtual ~Task() {} in ~Task() argument
|
| /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/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | ThreadEnvironment.h | 16 struct Task { struct
17 std::function<void()> f;
|