| /aosp_15_r20/external/rust/android-crates-io/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
|
| /aosp_15_r20/external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/ |
| H A 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
|
| /aosp_15_r20/external/swiftshader/third_party/llvm-16.0/llvm/include/llvm/Support/ |
| H A 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
|
| /aosp_15_r20/external/rust/android-crates-io/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> {} implementation
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
|
| /aosp_15_r20/external/cronet/base/task/sequence_manager/ |
| H A D | tasks.h | 103 struct BASE_EXPORT Task : public PendingTask { struct
112 Task& operator=(Task&& other); argument
128 TaskOrder task_order() const; argument
136 TaskType task_type; argument
140 scoped_refptr<SequencedTaskRunner> task_runner; argument
159 bool WillRunTask(); argument
174 WeakPtr<internal::DelayedTaskHandleDelegate> delayed_task_handle_delegate_; argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/task/ |
| D | mod.rs | 220 pub(crate) struct Task<S: 'static> { struct
221 raw: RawTask, argument
225 unsafe impl<S> Send for Task<S> {} implementation
226 unsafe impl<S> Sync for Task<S> {} implementation
344 impl<S: 'static> Task<S> { implementation
421 impl<S: Schedule> Task<S> { impl
482 impl<S: 'static> Drop for Task<S> { implementation
502 impl<S> fmt::Debug for Task<S> { implementation
517 unsafe impl<S> linked_list::Link for Task<S> { implementation
539 unsafe impl<S> sharded_list::ShardedListItem for Task<S> { implementation
|
| /aosp_15_r20/device/google/contexthub/firmware/os/inc/ |
| D | seos_priv.h | 52 struct Task { struct
63 struct TaskList list; argument
68 uint16_t tid;
70 uint8_t subbedEvtCount;
71 uint8_t subbedEvtListSz;
72 uint8_t flags;
73 uint8_t ioCount;
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/data/service/ |
| H A 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
|
| H A 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
|
| /aosp_15_r20/out/soong/.intermediates/external/libchrome/libchrome-include/gen/gensrcs/external/libchrome/base/task_scheduler/ |
| D | task.h | 27 struct BASE_EXPORT Task : public PendingTask { struct
44 Task& operator=(Task&& other); argument
47 TaskTraits traits; argument
62 // Sequence -> Task -> TaskRunner -> Sequence -> ... argument
67 scoped_refptr<SequencedTaskRunner> sequenced_task_runner_ref; argument
68 scoped_refptr<SingleThreadTaskRunner> single_thread_task_runner_ref; argument
|
| /aosp_15_r20/external/libchrome/base/task_scheduler/ |
| H A 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
|
| /aosp_15_r20/out/soong/.intermediates/external/libchrome/libchrome-include/gen/6/external/libchrome/base/task_scheduler/ |
| D | task.h | 27 struct BASE_EXPORT Task : public PendingTask { struct
44 Task& operator=(Task&& other); argument
47 TaskTraits traits; argument
62 // Sequence -> Task -> TaskRunner -> Sequence -> ... argument
67 scoped_refptr<SequencedTaskRunner> sequenced_task_runner_ref; argument
68 scoped_refptr<SingleThreadTaskRunner> single_thread_task_runner_ref; argument
|
| /aosp_15_r20/libcore/ojluni/src/test/java/util/concurrent/tck/ |
| H A D | CountedCompleter8Test.java | 71 class Task extends CountedCompleter<Void> { in forEach1() class
73 Task(Task parent, int lo, int hi) { in forEach1() method in CountedCompleter8Test.Task
95 class Task extends CountedCompleter<Void> { in forEach2() class
97 Task(Task parent, int lo, int hi) { in forEach2() method in CountedCompleter8Test.Task
119 class Task extends CountedCompleter<Void> { in forEach3() class
121 Task(Task parent, int lo, int hi) { in forEach3() method in CountedCompleter8Test.Task
141 class Task extends CountedCompleter<Void> { in forEach4() class
143 Task(Task parent, int lo, int hi) { in forEach4() method in CountedCompleter8Test.Task
|
| /aosp_15_r20/external/cronet/base/task/thread_pool/ |
| H A 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()
|
| /aosp_15_r20/external/swiftshader/src/Vulkan/ |
| H A 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;
|
| /aosp_15_r20/external/libchrome/mojo/public/cpp/bindings/lib/ |
| H A 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 …]
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sys/pal/sgx/ |
| H A D | thread.rs | 30 pub(super) struct Task { struct
31 p: Box<dyn FnOnce() + Send>,
32 done: JoinNotifier,
35 impl Task { impl
36 pub(super) fn new(p: Box<dyn FnOnce() + Send>) -> (Task, JoinHandle) { in new()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/sys/pal/sgx/ |
| H A D | thread.rs | 30 pub(super) struct Task { struct
31 p: Box<dyn FnOnce() + Send>,
32 done: JoinNotifier,
35 impl Task { implementation
36 pub(super) fn new(p: Box<dyn FnOnce() + Send>) -> (Task, JoinHandle) { in new()
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sys/pal/sgx/ |
| H A D | thread.rs | 30 pub(super) struct Task { struct
31 p: Box<dyn FnOnce() + Send>,
32 done: JoinNotifier,
35 impl Task { impl
36 pub(super) fn new(p: Box<dyn FnOnce() + Send>) -> (Task, JoinHandle) { in new()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sys/pal/sgx/ |
| H A D | thread.rs | 30 pub(super) struct Task { struct
31 p: Box<dyn FnOnce() + Send>,
32 done: JoinNotifier,
35 impl Task { impl
36 pub(super) fn new(p: Box<dyn FnOnce() + Send>) -> (Task, JoinHandle) { in new()
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sys/pal/sgx/ |
| H A D | thread.rs | 30 pub(super) struct Task { struct
31 p: Box<dyn FnOnce() + Send>,
32 done: JoinNotifier,
35 impl Task { impl
36 pub(super) fn new(p: Box<dyn FnOnce() + Send>) -> (Task, JoinHandle) { in new()
|
| /aosp_15_r20/external/rust/android-crates-io/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> { implementation
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/cmd/vendor/rsc.io/markdown/ |
| D | list.go | 320 type Task struct { struct
321 Checked bool
324 func (x *Task) Inline() {
327 func (x *Task) PrintHTML(buf *bytes.Buffer) {
335 func (x *Task) printMarkdown(buf *bytes.Buffer) {
339 func (x *Task) PrintText(buf *bytes.Buffer) {
|
| /aosp_15_r20/prebuilts/clang/host/linux-x86/clang-r522817/python3/lib/python3.11/site-packages/pip/_vendor/rich/ |
| D | progress.py | 509 def __call__(self, task: "Task") -> RenderableType:
533 def render(self, task: "Task") -> RenderableType:
550 def render(self, task: "Task") -> RenderableType:
595 def render(self, task: "Task") -> RenderableType:
623 def render(self, task: "Task") -> Text:
661 def render(self, task: "Task") -> ProgressBar:
679 def render(self, task: "Task") -> Text:
745 def render(self, task: "Task") -> Text:
782 def render(self, task: "Task") -> Text:
812 def render(self, task: "Task") -> Text:
[all …]
|
| /aosp_15_r20/prebuilts/clang/host/linux-x86/clang-r536225/python3/lib/python3.11/site-packages/pip/_vendor/rich/ |
| D | progress.py | 509 def __call__(self, task: "Task") -> RenderableType:
533 def render(self, task: "Task") -> RenderableType:
550 def render(self, task: "Task") -> RenderableType:
595 def render(self, task: "Task") -> RenderableType:
623 def render(self, task: "Task") -> Text:
661 def render(self, task: "Task") -> ProgressBar:
679 def render(self, task: "Task") -> Text:
745 def render(self, task: "Task") -> Text:
782 def render(self, task: "Task") -> Text:
812 def render(self, task: "Task") -> Text:
[all …]
|