| /third_party/skia/third_party/externals/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 …]
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/ |
| D | task.h | 47 class Task : public IntrpResource {
54 Task(const std::string &myName, const std::function<Status()> &f, int32_t operator_id = -1);
57 Task(const Task &) = delete;
59 ~Task() override;
61 Task &operator=(const Task &) = delete;
65 Task(Task &&) = delete;
67 Task &operator=(Task &&) = delete;
76 Node<Task> node;
77 Node<Task> group;
78 Node<Task> free;
[all …]
|
| D | task_manager.h | 78 …eateAsyncTask(const std::string &my_name, const std::function<Status()> &f, TaskGroup *vg, Task **,
87 static Task *FindMe();
89 static void InterruptGroup(Task &);
102 void ReturnFreeTask(Task *p) noexcept;
104 …Status GetFreeTask(const std::string &my_name, const std::function<Status()> &f, Task **p, int32_t…
114 std::shared_ptr<Task> master_;
115 List<Task> lru_;
116 List<Task> free_lst_;
122 Task *watchdog_;
130 friend class Task;
[all …]
|
| D | task_manager.cc | 28 Task **task, int32_t operator_id) { in CreateAsyncTask()
69 for (Task &tk : lru_) { in join_all()
93 Task *TaskManager::FindMe() { in FindMe()
100 …auto tk = std::find_if(tm.lru_.begin(), tm.lru_.end(), [id](const Task &tk) { return tk.id_ == id;… in FindMe()
116 lru_(&Task::node), in TaskManager()
117 free_lst_(&Task::free), in TaskManager()
120 auto alloc = Services::GetAllocator<Task>(); in TaskManager()
122 master_ = std::allocate_shared<Task>(alloc, "master", []() -> Status { return Status::OK(); }); in TaskManager()
203 void TaskManager::InterruptGroup(Task &curTk) { in InterruptGroup()
210 std::shared_ptr<Task> master = tm.master_; in InterruptMaster()
[all …]
|
| D | task.cc | 33 thread_local Task *gMyTask = nullptr;
35 void Task::operator()() { in operator ()()
82 void Task::ShutdownGroup() { // Wake up watch dog and shutdown the engine. in ShutdownGroup()
102 Status Task::GetTaskErrorIfAny() const { in GetTaskErrorIfAny()
111 Task::Task(const std::string &myName, const std::function<Status()> &f, int32_t operator_id) in Task() function in mindspore::dataset::Task
126 Status Task::Run() { in Run()
140 Status Task::Join(WaitFlag blocking) { in Join()
199 TaskGroup *Task::MyTaskGroup() { return task_group_; } in MyTaskGroup()
201 void Task::set_task_group(TaskGroup *vg) { task_group_ = vg; } in set_task_group()
203 Task::~Task() { task_group_ = nullptr; } in ~Task()
[all …]
|
| /third_party/typescript/tests/baselines/reference/ |
| D | asyncImportedPromise_es5.types | 2 export class Task<T> extends Promise<T> { }
3 >Task : Task<T>
7 import { Task } from "./task";
8 >Task : typeof Task
13 async example<T>(): Task<T> { return; }
14 >example : <T>() => Task<T>
|
| D | asyncImportedPromise_es6.types | 2 export class Task<T> extends Promise<T> { }
3 >Task : Task<T>
7 import { Task } from "./task";
8 >Task : typeof Task
13 async example<T>(): Task<T> { return; }
14 >example : <T>() => Task<T>
|
| D | asyncImportedPromise_es5.symbols | 2 export class Task<T> extends Promise<T> { }
3 >Task : Symbol(Task, Decl(task.ts, 0, 0))
9 import { Task } from "./task";
10 >Task : Symbol(Task, Decl(test.ts, 0, 8))
15 async example<T>(): Task<T> { return; }
18 >Task : Symbol(Task, Decl(test.ts, 0, 8))
|
| D | asyncImportedPromise_es6.symbols | 2 export class Task<T> extends Promise<T> { }
3 >Task : Symbol(Task, Decl(task.ts, 0, 0))
9 import { Task } from "./task";
10 >Task : Symbol(Task, Decl(test.ts, 0, 8))
15 async example<T>(): Task<T> { return; }
18 >Task : Symbol(Task, Decl(test.ts, 0, 8))
|
| D | asyncImportedPromise_es6.js | 4 export class Task<T> extends Promise<T> { } class
7 import { Task } from "./task";
9 async example<T>(): Task<T> { return; } field in Test
15 exports.Task = void 0;
16 class Task extends Promise {
18 exports.Task = Task;
|
| D | asyncImportedPromise_es5.js | 4 export class Task<T> extends Promise<T> { } class
7 import { Task } from "./task";
9 async example<T>(): Task<T> { return; } field in Test
30 exports.Task = void 0;
31 var Task = /** @class */ (function (_super) {
32 __extends(Task, _super);
33 function Task() { class in Task
36 return Task;
38 exports.Task = Task;
83 … return __awaiter(this, void 0, task_1.Task, function () { return __generator(this, function (_a) {
|
| D | mappedTypeAsClauses.types | 194 type Task = {
195 >Task : Task
206 >root : { title: string; task: Task; }
211 task: Task;
212 >task : Task
214 Task: Task;
215 >Task : Task
219 type Res1 = GetKey<Schema, Schema['root']['task']>; // "Task"
220 >Res1 : "Task"
222 type Res2 = GetKeyWithIf<Schema, Schema['root']['task']>; // "Task"
[all …]
|
| /third_party/mindspore/mindspore/ccsrc/backend/session/ |
| D | executor.h | 52 class Task {
54 Task() = default;
55 virtual ~Task() = default;
62 class CompileNodesTask : public Task {
72 class CompileGraphTask : public Task {
81 class BuildGraphTask : public Task {
89 class RunGraphTask : public Task {
102 class RunOpsInGraphTask : public Task {
112 class RunOpTask : public Task {
124 class CreateCommGroupTask : public Task {
[all …]
|
| /third_party/skia/third_party/externals/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()
|
| /third_party/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()
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/ |
| D | AsyncUnaryCall.cs | 31 readonly Task<TResponse> responseAsync;
43 public AsyncUnaryCall(Task<TResponse> responseAsync, in AsyncUnaryCall()
44 Task<Metadata> responseHeadersAsync, in AsyncUnaryCall()
62 public AsyncUnaryCall(Task<TResponse> responseAsync, in AsyncUnaryCall()
63 Func<object, Task<Metadata>> responseHeadersAsync, in AsyncUnaryCall()
76 public Task<TResponse> ResponseAsync
87 public Task<Metadata> ResponseHeadersAsync
|
| D | AsyncClientStreamingCall.cs | 33 readonly Task<TResponse> responseAsync;
46 Task<TResponse> responseAsync, in AsyncClientStreamingCall()
47 Task<Metadata> responseHeadersAsync, in AsyncClientStreamingCall()
68 Task<TResponse> responseAsync, in AsyncClientStreamingCall()
69 Func<object, Task<Metadata>> responseHeadersAsync, in AsyncClientStreamingCall()
83 public Task<TResponse> ResponseAsync
94 public Task<Metadata> ResponseHeadersAsync
|
| /third_party/node/src/ |
| D | node_platform.h | 46 std::unique_ptr<v8::Task> task;
62 void PostTask(std::unique_ptr<v8::Task> task) override;
64 void PostDelayedTask(std::unique_ptr<v8::Task> task,
71 void PostNonNestableTask(std::unique_ptr<v8::Task> task) override;
72 void PostNonNestableDelayedTask(std::unique_ptr<v8::Task> task,
90 void RunForegroundTask(std::unique_ptr<v8::Task> task);
106 TaskQueue<v8::Task> foreground_tasks_;
120 void PostTask(std::unique_ptr<v8::Task> task);
121 void PostDelayedTask(std::unique_ptr<v8::Task> task,
130 TaskQueue<v8::Task> pending_worker_tasks_;
[all …]
|
| D | node_platform.cc | 15 using v8::Task;
20 TaskQueue<Task>* task_queue;
31 TaskQueue<Task>* pending_worker_tasks = worker_data->task_queue; in PlatformWorkerThread()
42 while (std::unique_ptr<Task> task = pending_worker_tasks->BlockingPop()) { in PlatformWorkerThread()
52 explicit DelayedTaskScheduler(TaskQueue<Task>* tasks) in DelayedTaskScheduler()
67 void PostDelayedTask(std::unique_ptr<Task> task, double delay_in_seconds) { in PostDelayedTask()
95 while (std::unique_ptr<Task> task = scheduler->tasks_.Pop()) in FlushTasks()
99 class StopTask : public Task {
117 class ScheduleTask : public Task {
120 std::unique_ptr<Task> task, in ScheduleTask()
[all …]
|
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | AsyncCall.cs | 141 return unaryResponseTcs.Task.GetAwaiter().GetResult(); in UnaryCall()
148 public Task<TResponse> UnaryCallAsync(TRequest msg) in UnaryCallAsync()
174 return unaryResponseTcs.Task; in UnaryCallAsync()
190 public Task<TResponse> ClientStreamingCallAsync() in ClientStreamingCallAsync()
211 return unaryResponseTcs.Task; in ClientStreamingCallAsync()
299 public Task SendMessageAsync(TRequest msg, WriteFlags writeFlags) in SendMessageAsync()
307 public Task<TResponse> ReadMessageAsync() in ReadMessageAsync()
316 public Task SendCloseFromClientAsync() in SendCloseFromClientAsync()
340 return streamingWriteTcs.Task; in SendCloseFromClientAsync()
347 public Task StreamingResponseCallFinishedTask
[all …]
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/ |
| D | ContextPropagationTest.cs | 55 public async Task PropagateCancellation() in PropagateCancellation()
66 await Task.Delay(10); in PropagateCancellation()
91 await readyToCancelTcs.Task; in PropagateCancellation()
102 Assert.AreEqual("CHILD_CALL_CANCELLED", await successTcs.Task); in PropagateCancellation()
106 public async Task PropagateDeadline() in PropagateDeadline()
113 return Task.FromResult("PASS"); in PropagateDeadline()
136 public async Task SuppressDeadlinePropagation() in SuppressDeadlinePropagation()
141 return Task.FromResult("PASS"); in SuppressDeadlinePropagation()
165 public async Task ForeignPropagationTokenIsIgnored() in ForeignPropagationTokenIsIgnored()
169 return Task.FromResult("PASS"); in ForeignPropagationTokenIsIgnored()
|
| /third_party/glslang/Test/baseResults/ |
| D | spv.meshTaskShader.task.out | 29 Name 88 "Task"
30 MemberName 88(Task) 0 "dummy"
31 MemberName 88(Task) 1 "submesh"
32 MemberName 88(Task) 2 "viewID"
47 MemberDecorate 88(Task) 0 PerTaskNV
48 MemberDecorate 88(Task) 0 Offset 0
49 MemberDecorate 88(Task) 1 PerTaskNV
50 MemberDecorate 88(Task) 1 Offset 8
51 MemberDecorate 88(Task) 2 PerTaskNV
52 MemberDecorate 88(Task) 2 Offset 32
[all …]
|
| /third_party/mindspore/.github/ISSUE_TEMPLATE/ |
| D | task-tracking.md | 2 name: Task
8 ## Task Description
11 ## Task Goal
14 ## Sub Task
15 | No. | Task Description | Issue ID |
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/LTO/ |
| D | Caching.cpp | 35 return [=](unsigned Task, StringRef Key) -> AddStreamFn { in localCache() argument
52 AddBuffer(Task, std::move(*MBOrErr)); in localCache()
76 unsigned Task; in localCache() member
80 unsigned Task) in localCache()
83 Task(Task) {} in localCache()
129 AddBuffer(Task, std::move(*MBOrErr)); in localCache()
133 return [=](size_t Task) -> std::unique_ptr<NativeObjectStream> { in localCache() argument
147 AddBuffer, std::move(*Temp), EntryPath.str(), Task); in localCache()
|
| /third_party/flutter/engine/flutter/shell/platform/glfw/ |
| D | glfw_event_loop.h | 44 struct Task { struct
50 bool operator()(const Task& a, const Task& b) { in operator() argument
61 std::priority_queue<Task, std::deque<Task>, Task::Comparer> task_queue_;
|