Home
last modified time | relevance | path

Searched refs:TaskGroup (Results 1 – 25 of 33) sorted by relevance

12

/third_party/typescript/tests/baselines/reference/
DjsDeclarationsTypedefPropertyAndExportAssignment.js108 export type TaskGroup = {
135 [x: string]: TaskGroup;
152 constructor(x: TaskGroup, y: TaskNode);
155 export { TaskGroup, TaskNode, PriorTaskData };
157 type TaskGroup = import('./module.js').TaskGroup;
161 group: TaskGroup;
DjsDeclarationsTypedefPropertyAndExportAssignment.types4 …meToGroup : { [x: string]: import("tests/cases/conformance/jsdoc/declarations/module").TaskGroup; }
9 /** @typedef {import('./module.js').TaskGroup} TaskGroup */
15 * @prop {TaskGroup} group
23 * @param {TaskGroup} x
27 >x : import("tests/cases/conformance/jsdoc/declarations/module").TaskGroup
42 * @typedef TaskGroup
83 /** @type {Object<string, TaskGroup>} */
85 >taskNameToGroup : { [x: string]: TaskGroup; }
93 …leLayout: { id: "styleLayout"; label: string; }; }; taskNameToGroup: { [x: string]: TaskGroup; }; }
99 >taskNameToGroup : { [x: string]: TaskGroup; }
DjsDeclarationsTypedefPropertyAndExportAssignment.symbols8 /** @typedef {import('./module.js').TaskGroup} TaskGroup */
14 * @prop {TaskGroup} group
22 * @param {TaskGroup} x
40 * @typedef TaskGroup
74 /** @type {Object<string, TaskGroup>} */
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/
Dtask_manager.cc27 …nager::CreateAsyncTask(const std::string &my_name, const std::function<Status()> &f, TaskGroup *vg, in CreateAsyncTask()
81 for (TaskGroup *vg : grp_list_) { in interrupt_all()
165 watchdog_grp_ = new (&rc, mp) TaskGroup(); in DoServiceStart()
204 TaskGroup *vg = curTk.MyTaskGroup(); in InterruptGroup()
280 Status TaskGroup::CreateAsyncTask(const std::string &my_name, const std::function<Status()> &f, Tas… in CreateAsyncTask()
308 void TaskGroup::interrupt_all() noexcept { in interrupt_all()
316 Status TaskGroup::join_all(Task::WaitFlag wf) { in join_all()
329 Status TaskGroup::DoServiceStop() { in DoServiceStop()
334 TaskGroup::TaskGroup() : grp_list_(&Task::group), intrp_svc_(nullptr) { in TaskGroup() function in mindspore::dataset::TaskGroup
340 TaskGroup::~TaskGroup() { in ~TaskGroup()
[all …]
Dtask_manager.h49 friend class TaskGroup; variable
78 …Status CreateAsyncTask(const std::string &my_name, const std::function<Status()> &f, TaskGroup *vg…
120 TaskGroup *watchdog_grp_;
121 std::set<TaskGroup *> grp_list_;
128 class TaskGroup : public Service {
148 TaskGroup();
150 ~TaskGroup() override;
DREADME.md11 … create a Task object directly. Most work will go through TaskManager's TaskGroup interface which …
101 …see later, the value of rc_ will be propagated to high level classes like TaskGroup, master thread.
123 ## TaskGroup section
125 …jects is TaskGroup. Technically speaking a TaskGroup is a collection of related Tasks. As of this …
128 Status TaskGroup::CreateAsyncTask(const std::string &my_name, const std::function<Status()> &f, Tas…
131 The created Task object is added to the TaskGroup object. In many cases, user do not need to get a …
133TaskGroup other than by calling TaskGroup::CreateAsyncTask. As a result, no Task object can belong…
136 TaskGroup *Task::MyTaskGroup();
139 Task objects in the same TaskGroup will form a linked list with newly created Task object appended …
141 …er (discussed in the next section) will chain all Task objects from all TaskGroup's in a single LR…
[all …]
Dtask.h50 friend class TaskGroup; variable
125 TaskGroup *task_group_;
139 TaskGroup *MyTaskGroup();
140 void set_task_group(TaskGroup *vg);
Dwait_post.h25 class TaskGroup; variable
39 Status Register(TaskGroup *vg);
Dtask.cc56 TaskGroup *vg = MyTaskGroup(); in operator ()()
87 TaskGroup *vg = MyTaskGroup(); in ShutdownGroup()
199 TaskGroup *Task::MyTaskGroup() { return task_group_; } in MyTaskGroup()
201 void Task::set_task_group(TaskGroup *vg) { task_group_ = vg; } in set_task_group()
Dsemaphore.h23 class TaskGroup; variable
42 Status Register(TaskGroup *vg);
Dsemaphore.cc33 Status Semaphore::Register(TaskGroup *vg) { return wait_cond_.Register(vg->GetIntrpService()); } in Register()
Dqueue.h152 Status Register(TaskGroup *vg) { in Register()
187 Status Register(TaskGroup *vg) { in Register()
Dwait_post.cc39 Status WaitPost::Register(TaskGroup *vg) { return wait_cond_.Register(vg->GetIntrpService()); } in Register()
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Support/
DParallel.cpp146 TaskGroup::TaskGroup() : Parallel(TaskGroupInstances++ == 0) {} in TaskGroup() function in llvm::parallel::detail::TaskGroup
147 TaskGroup::~TaskGroup() { --TaskGroupInstances; } in ~TaskGroup()
149 void TaskGroup::spawn(std::function<void()> F) { in spawn()
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/
DParallel.h66 class TaskGroup {
71 TaskGroup();
72 ~TaskGroup();
96 const Comparator &Comp, TaskGroup &TG, size_t Depth) { in parallel_quick_sort()
123 TaskGroup TG; in parallel_sort()
138 TaskGroup TG; in parallel_for_each()
152 TaskGroup TG; in parallel_for_each_n()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/
Dexecution_tree.h38 class TaskGroup; variable
168 TaskGroup *const AllTasks() const { return tg_.get(); } in AllTasks()
208 std::unique_ptr<TaskGroup> tg_; // Class for worker management
Dtree_adapter.h65 TaskGroup *const AllTasks() const { return tree_ ? tree_->AllTasks() : nullptr; } in AllTasks()
/third_party/mindspore/tests/ut/cpp/dataset/
Dtask_manager_test.cc33 TaskGroup vg; in TEST_F()
61 TaskGroup vg; in TEST_F()
Dinterrupt_test.cc34 TaskGroup vg_;
Dconnector_test.cc54 std::unique_ptr<TaskGroup> tg_;
128 MindDataTestConnector::MindDataTestConnector() : tg_(new TaskGroup()) { in MindDataTestConnector()
Dcircular_pool_test.cc36 TaskGroup vg_;
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/perf/
Dcache_perf_run.h86 TaskGroup vg_;
Dcache_pipeline_run.h100 TaskGroup vg_;
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_grpc_client.h98 TaskGroup vg_;
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/
Dgraph_data_server.cc37 tg_ = std::make_unique<TaskGroup>(); in GraphDataServer()

12