Home
last modified time | relevance | path

Searched refs:kBlocking (Results 1 – 7 of 7) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/
Dtask.h52 enum class WaitFlag : int { kBlocking, kNonBlocking }; enumerator
83 Status Join(WaitFlag wf = WaitFlag::kBlocking);
Dtask_manager.h138 Status join_all(Task::WaitFlag wf = Task::WaitFlag::kBlocking);
Dtask.cc145 if (blocking == WaitFlag::kBlocking) { in Join()
DREADME.md70 Status Task::Join(WaitFlag wf = WaitFlag::kBlocking);
76 enum class WaitFlag : int { kBlocking, kNonBlocking };
81 This function blocks (kBlocking) by default until the spawned thread returns.
166 Status TaskGroup::join_all(Task::WaitFlag wf = Task::WaitFlag::kBlocking);
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/perf/
Dcache_pipeline_run.cc245 RETURN_IF_NOT_OK(pTask->Join(Task::WaitFlag::kBlocking)); in RunFirstEpoch()
390 RETURN_IF_NOT_OK(pTask->Join(Task::WaitFlag::kBlocking)); in RunReadEpoch()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/
Dgraph_loader.cc131 RETURN_IF_NOT_OK(vg.join_all(Task::WaitFlag::kBlocking)); in InitAndLoad()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_server.cc1037 RETURN_IF_NOT_OK(vg_.join_all(Task::WaitFlag::kBlocking)); in Run()