| /external/swiftshader/third_party/marl/include/marl/ |
| D | task.h | 25 class Task {
39 MARL_NO_EXPORT inline Task();
40 MARL_NO_EXPORT inline Task(const Task&);
41 MARL_NO_EXPORT inline Task(Task&&);
42 MARL_NO_EXPORT inline Task(const Function& function,
44 MARL_NO_EXPORT inline Task(Function&& function, Flags flags = Flags::None);
45 MARL_NO_EXPORT inline Task& operator=(const Task&);
46 MARL_NO_EXPORT inline Task& operator=(Task&&);
47 MARL_NO_EXPORT inline Task& operator=(const Function&);
48 MARL_NO_EXPORT inline Task& operator=(Function&&);
[all …]
|
| /external/llvm-project/lldb/test/API/python_api/value/linked_list/ |
| D | main.cpp | 3 class Task { class
6 Task *next;
7 Task(int i, Task *n): in Task() function in Task
16 Task *task_head = NULL; in main()
17 Task *task1 = new Task(1, NULL); in main()
18 Task *task2 = new Task(2, NULL); in main()
19 Task *task3 = new Task(3, NULL); // Orphaned. in main()
20 Task *task4 = new Task(4, NULL); in main()
21 Task *task5 = new Task(5, NULL); in main()
29 Task *t = task_head; in main()
[all …]
|
| /external/llvm-project/lldb/test/API/python_api/type/ |
| D | main.cpp | 3 class Task { class
6 Task *next;
25 Task(int i, Task *n): in Task() function in Task
35 Task *task_head = new Task(-1, NULL); in main()
36 Task *task1 = new Task(1, NULL); in main()
37 Task *task2 = new Task(2, NULL); in main()
38 Task *task3 = new Task(3, NULL); // Orphaned. in main()
39 Task *task4 = new Task(4, NULL); in main()
40 Task *task5 = new Task(5, NULL); in main()
48 Task *t = task_head; in main()
[all …]
|
| /external/vogar/src/vogar/tasks/ |
| D | Task.java | 30 public abstract class Task { class
32 final List<Task> tasksThatMustFinishFirst = new ArrayList<Task>();
33 final List<Task> tasksThatMustFinishSuccessfullyFirst = new ArrayList<Task>();
37 protected Task(String name) { in Task() method in Task
49 public Task after(Task prerequisite) { in after()
54 public Task after(Collection<Task> prerequisites) { in after()
59 public Task afterSuccess(Task prerequisite) { in afterSuccess()
64 public Task afterSuccess(Collection<Task> prerequisitess) { in afterSuccess()
70 for (Task task : tasksThatMustFinishFirst) { in isRunnable()
75 for (Task task : tasksThatMustFinishSuccessfullyFirst) { in isRunnable()
|
| D | TaskQueue.java | 39 private final LinkedList<Task> tasks = new LinkedList<Task>();
40 private final LinkedList<Task> runnableActions = new LinkedList<Task>();
41 private final LinkedList<Task> runnableTasks = new LinkedList<Task>();
42 private final List<Task> failedTasks = new ArrayList<Task>();
52 public synchronized void enqueue(Task task) { in enqueue()
56 public void enqueueAll(Collection<Task> tasks) { in enqueueAll()
60 public synchronized List<Task> getTasks() { in getTasks()
61 return new ArrayList<Task>(tasks); in getTasks()
91 for (Task task : tasks) { in printTasks()
94 for (Task blocker : task.tasksThatMustFinishFirst) { in printTasks()
[all …]
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | mod.rs | 38 pub(crate) struct Task<S: 'static> { struct
43 unsafe impl<S> Send for Task<S> {} argument
44 unsafe impl<S> Sync for Task<S> {} implementation
48 pub(crate) struct Notified<S: 'static>(Task<S>);
62 fn bind(task: Task<Self>) -> Self; in bind()
70 fn release(&self, task: &Task<Self>) -> Option<Task<Self>>; in release()
91 let task = Task {
111 let task = Task {
122 impl<S: 'static> Task<S> { impl
123 pub(crate) unsafe fn from_raw(ptr: NonNull<Header>) -> Task<S> { in from_raw()
[all …]
|
| /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
10 return Task{coroutine_handle<promise_type>::from_promise(*this)}; in get_return_object()
53 Task(handle_t coro) noexcept : coro_(coro) {} in Task() argument
57 Task(const Task &t) = delete; argument
58 Task(Task &&t) noexcept;
59 ~Task();
60 Task &operator=(Task t) noexcept;
65 static Task foo() { in foo()
69 Task bar() { in bar()
|
| /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
10 return Task{coro::coroutine_handle<promise_type>::from_promise(*this)}; in get_return_object()
53 Task(handle_t coro) noexcept : coro_(coro) {} in Task() argument
57 Task(const Task &t) = delete; argument
58 Task(Task &&t) noexcept;
59 ~Task();
60 Task &operator=(Task t) noexcept;
65 static Task foo() { in foo()
69 Task bar() { in bar()
|
| /external/llvm-project/clang-tools-extra/clangd/unittests/support/ |
| D | CancellationTests.cpp | 16 auto Task = cancelableTask(); in TEST() local
17 WithContext ContextWithCancellation(std::move(Task.first)); in TEST()
19 Task.second(); in TEST()
26 auto Task = cancelableTask(); in TEST() local
27 ContextWithCancellation.emplace(std::move(Task.first)); in TEST()
29 Task.second(); in TEST()
36 auto Task = cancelableTask(); in TEST() local
38 WithContext ContextWithCancellation(std::move(Task.first)); in TEST()
40 Task.second(); in TEST()
44 Task.second(); in TEST()
[all …]
|
| /external/libchrome/base/task_scheduler/ |
| 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
61 Task::~Task() = default;
63 Task& Task::operator=(Task&& other) = default;
|
| D | task.h | 24 struct BASE_EXPORT Task : public PendingTask { struct
30 Task(const Location& posted_from,
37 Task(Task&& other) noexcept;
39 ~Task();
41 Task& operator=(Task&& other); argument
68 DISALLOW_COPY_AND_ASSIGN(Task);
|
| D | task_tracker_unittest.cc | 90 Task* task, in ThreadPostingAndRunningTask()
107 Task task, in ThreadPostingAndRunningTask()
144 Task owned_task_;
145 Task* task_;
171 Task CreateTask(TaskShutdownBehavior shutdown_behavior) { in CreateTask()
172 return Task( in CreateTask()
178 void DispatchAndRunTaskWithTracker(Task task) { in DispatchAndRunTaskWithTracker()
283 Task task(CreateTask(GetParam())); in TEST_P()
305 Task blocked_task( in TEST_P()
347 Task task(CreateTask(GetParam())); in TEST_P()
[all …]
|
| /external/llvm/lib/Support/ |
| D | ThreadPool.cpp | 34 PackagedTaskTy Task; in ThreadPool() local
52 Task = std::move(Tasks.front()); in ThreadPool()
57 Task(); in ThreadPool()
59 Task(/* unused */ false); in ThreadPool()
85 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
87 PackagedTaskTy PackagedTask(std::move(Task)); in asyncImpl()
129 auto Task = std::move(Tasks.front()); in wait() local
132 Task(); in wait()
134 Task(/* unused */ false); in wait()
139 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
[all …]
|
| /external/llvm-project/llvm/utils/vscode/llvm/src/ |
| D | litTaskProvider.ts | 15 private litPromise: Thenable<vscode.Task[]> | undefined = undefined;
28 public provideTasks(): Thenable<vscode.Task[]> | undefined {
35 public resolveTask(_task: vscode.Task): vscode.Task | undefined {
46 return new vscode.Task(
57 private async getLITTasks(): Promise<vscode.Task[]> {
58 let result: vscode.Task[] = [];
66 result.push(new vscode.Task({ type: 'llvm-lit', task: taskName },
72 result.push(new vscode.Task({ type: 'llvm-lit', task: taskName },
|
| /external/vogar/src/vogar/android/ |
| D | ActivityMode.java | 29 import vogar.tasks.Task;
41 @Override public Set<Task> installTasks() { in installTasks()
42 return Collections.<Task>singleton( in installTasks()
46 @Override public Set<Task> installActionTasks(Action action, File jar) { in installActionTasks()
47 return Collections.<Task>singleton(new InstallApkTask(run, action, jar)); in installActionTasks()
50 @Override public Task executeActionTask(Action action, boolean useLargeTimeout) { in executeActionTask()
54 @Override public Set<Task> cleanupTasks(Action action) { in cleanupTasks()
55 Set<Task> result = new LinkedHashSet<Task>(); in cleanupTasks()
|
| D | DeviceRuntime.java | 36 import vogar.tasks.Task;
57 @Override public Set<Task> installTasks() { in installTasks()
58 Set<Task> result = new HashSet<Task>(); in installTasks()
67 @Override public Set<Task> installActionTasks(Action action, File jar) { in installActionTasks()
68 Set<Task> result = new HashSet<Task>(); in installActionTasks()
73 @Override public Task executeActionTask(Action action, boolean useLargeTimeout) { in executeActionTask()
117 @Override public Set<Task> cleanupTasks(Action action) { in cleanupTasks()
135 Set<Task> tasks, String name, File jar, Action action) { in addCreateDexJarAndPushTasks()
139 Task createDexJarTask = newCreateDexJarTask(run.classpath, jar, name, action, localDex, in addCreateDexJarAndPushTasks()
145 private Task newCreateDexJarTask(Classpath classpath, File classpathElement, String name, in newCreateDexJarTask()
|
| /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 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/ims/rcs/rcsservice/src/com/android/service/ims/ |
| D | TaskManager.java | 66 private Map<String, Task> mTaskMap;
77 mTaskMap = new HashMap<String, Task>(); in TaskManager()
99 public void putTask(int taskId, Task task){ in putTask()
105 private synchronized void putTaskInternal(int taskId, Task task){ in putTaskInternal()
106 Task sameKeyTask = mTaskMap.put(String.valueOf(taskId), task); in putTaskInternal()
115 Task task = new PresenceCapabilityTask(context, taskId, TASK_TYPE_GET_CAPABILITY, in addCapabilityTask()
128 Task task = new PresenceAvailabilityTask(taskId, TASK_TYPE_GET_AVAILABILITY, in addAvailabilityTask()
141 Task task = new PresenceTask(taskId, TASK_TYPE_PUBLISH, null /*listener*/, contacts); in addPublishTask()
149 public Task getTask(int taskId){ in getTask()
157 Task task = mTaskMap.remove(String.valueOf(taskId)); in removeTask()
[all …]
|
| /external/rust/crates/async-task/ |
| D | CHANGELOG.md | 15 - Rename `Task` to `Runnable`.
16 - Rename `JoinHandle` to `Task`.
17 - Cancel `Task` on drop.
18 - Add `Task::detach()` and `Task::cancel()`.
36 - Return `true` in `Task::run()`.
53 - Add `Task::waker` and `JoinHandle::waker`.
54 - Add `Task::into_raw` and `Task::from_raw`.
|
| /external/libchrome/base/task/sequence_manager/ |
| D | task_queue_impl.h | 107 class BASE_EXPORT Task : public TaskQueue::Task {
109 Task(TaskQueue::PostedTask task,
113 Task(TaskQueue::PostedTask task,
169 internal::TaskQueueImpl::Task task;
176 RepeatingCallback<void(const TaskQueue::Task&,
179 RepeatingCallback<void(const TaskQueue::Task&,
269 void PushImmediateIncomingTaskForTest(TaskQueueImpl::Task&& task);
296 void OnTaskStarted(const TaskQueue::Task& task,
299 void OnTaskCompleted(const TaskQueue::Task& task,
352 std::priority_queue<TaskQueueImpl::Task> delayed_incoming_queue;
[all …]
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
| D | ThreadPool.cpp | 34 PackagedTaskTy Task; in ThreadPool() local
52 Task = std::move(Tasks.front()); in ThreadPool()
56 Task(); in ThreadPool()
81 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
83 PackagedTaskTy PackagedTask(std::move(Task)); in asyncImpl()
125 auto Task = std::move(Tasks.front()); in wait() local
127 Task(); in wait()
131 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
133 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); in asyncImpl()
|
| /external/llvm-project/llvm/lib/Support/ |
| D | ThreadPool.cpp | 32 PackagedTaskTy Task; in ThreadPool() local
47 Task = std::move(Tasks.front()); in ThreadPool()
51 Task(); in ThreadPool()
75 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
77 PackagedTaskTy PackagedTask(std::move(Task)); in asyncImpl()
117 auto Task = std::move(Tasks.front()); in wait() local
119 Task(); in wait()
123 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
125 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); in asyncImpl()
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | InteropClientServerTest.cs | 81 public async Task ClientStreaming() in ClientStreaming()
87 public async Task ServerStreaming() in ServerStreaming()
93 public async Task PingPong() in PingPong()
99 public async Task EmptyStream() in EmptyStream()
105 public async Task CancelAfterBegin() in CancelAfterBegin()
111 public async Task CancelAfterFirstResponse() in CancelAfterFirstResponse()
117 public async Task TimeoutOnSleepingServer() in TimeoutOnSleepingServer()
123 public async Task CustomMetadata() in CustomMetadata()
129 public async Task StatusCodeAndMessage() in StatusCodeAndMessage()
|
| /external/llvm-project/clang-tools-extra/clangd/index/ |
| D | BackgroundQueue.cpp | 23 llvm::Optional<Task> Task; in work() local
34 Task = std::move(Queue.back()); in work()
39 if (Task->ThreadPri != llvm::ThreadPriority::Default && in work()
41 llvm::set_thread_priority(Task->ThreadPri); in work()
42 Task->Run(); in work()
43 if (Task->ThreadPri != llvm::ThreadPriority::Default) in work()
75 void BackgroundQueue::push(Task T) { in push()
87 void BackgroundQueue::append(std::vector<Task> Tasks) { in append()
90 for (Task &T : Tasks) in append()
109 for (Task &T : Queue) in boost()
|
| /external/openscreen/platform/test/ |
| D | fake_task_runner.h | 45 using Task = TaskRunner::Task;
54 void PostPackagedTask(Task task) override;
55 void PostPackagedTaskWithDelay(Task task, Clock::duration delay) override;
68 std::vector<Task> ready_to_run_tasks_;
69 std::multimap<Clock::time_point, Task> delayed_tasks_;
|