| /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() 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/tensorflow/tensorflow/core/data/service/ |
| D | worker_impl.h | 80 struct Task { struct
81 explicit Task(TaskDef task_def) : task_def(std::move(task_def)) {} in Task() function
83 TaskDef task_def; argument
87 std::unique_ptr<TaskRunner> task_runner; argument
95 Status EnsureTaskInitialized(Task& task); argument
|
| D | dispatcher_state.h | 183 struct Task { struct
184 explicit Task(int64_t task_id, const std::shared_ptr<Job>& job, in Task() function
201 using TasksById = absl::flat_hash_map<int64, 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> {} implementation
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
400 impl<T> Drop for Task<T> { implementation
407 impl<T> Future for Task<T> { implementation
418 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/rust/crates/tokio/src/runtime/task/ |
| D | mod.rs | 178 pub(crate) struct Task<S: 'static> { struct
179 raw: RawTask, argument
183 unsafe impl<S> Send for Task<S> {} argument
184 unsafe impl<S> Sync for Task<S> {} implementation
288 impl<S: 'static> Task<S> { implementation
314 impl<S: 'static> Task<S> { impl
329 impl<S: Schedule> Task<S> { impl
389 impl<S: 'static> Drop for Task<S> { implementation
409 impl<S> fmt::Debug for Task<S> { implementation
424 unsafe impl<S> linked_list::Link for Task<S> { implementation
|
| /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> { implementation
25 impl<T> Task<T> { implementation
|
| /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/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 | 297 struct Task { struct
304 mutex: UnparkMutex<Task>, argument
308 impl Task { impl
341 impl fmt::Debug for Task { implementation
|
| /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;
|
| /external/vogar/src/vogar/tasks/ |
| D | Task.java | 30 public abstract class Task { class
37 protected Task(String name) { in Task() method in Task
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | data_service_dataset_op.cc | 397 struct Task { struct in tensorflow::data::DataServiceDatasetOp::Dataset::Iterator
398 Task(const TaskInfo& info, in Task() argument
402 const TaskInfo info;
404 const std::unique_ptr<DataServiceWorkerClient> worker;
406 int64 round = 0;
409 bool removed = false;
410 bool skipped_previous_round = false;
|
| /external/webrtc/modules/desktop_capture/ |
| D | screen_drawer_unittest.cc | 42 class Task { in TestScreenDrawerLock() class
44 Task(std::atomic<bool>* created, in TestScreenDrawerLock() function in webrtc::__anon6b89a26e0111::TestScreenDrawerLock::Task
|
| /external/gemmlowp/internal/ |
| D | multi_thread_gemm.h | 213 struct Task { struct
214 Task() : local_allocator(nullptr) {} in Task() argument
215 virtual ~Task() {} in ~Task() argument
217 Allocator* local_allocator;
|
| /external/skia/dm/ |
| D | DM.cpp | 1120 struct Task { struct
1121 Task(const TaggedSrc& src, const TaggedSink& sink) : src(src), sink(sink) {} in Task() function
1125 static void Run(const Task& task) { in Run() argument
1267 static SkString identify_gamut(SkColorSpace* cs) { in identify_gamut()
1293 static SkString identify_transfer_fn(SkColorSpace* cs) { in identify_transfer_fn()
1336 static void WriteToDisk(const Task& task, in WriteToDisk() argument
1416 static void RunGMVerifiers(const Task& task, const SkBitmap& actualBitmap) { in RunGMVerifiers() argument
|
| /external/swiftshader/third_party/marl/src/ |
| D | non_marl_bench.cpp | 56 using Task = std::function<uint32_t(uint32_t)>; in SingleQueueTaskExecutor() typedef
123 using Task = std::function<uint32_t(uint32_t)>; in MultiQueueTaskExecutor() typedef
|