Home
last modified time | relevance | path

Searched refs:kNonBlocking (Results 1 – 8 of 8) sorted by relevance

/third_party/mindspore/tests/ut/cpp/dataset/
Dinterrupt_test.cc50 vg_.join_all(Task::WaitFlag::kNonBlocking); in TEST_F()
66 vg_.join_all(Task::WaitFlag::kNonBlocking); in TEST_F()
Dconnector_test.cc170 tg_->join_all(Task::WaitFlag::kNonBlocking); in Run_test_0()
237 tg_->join_all(Task::WaitFlag::kNonBlocking); in Run_test_1()
Dtask_manager_test.cc84 ASSERT_TRUE(vg.join_all(Task::WaitFlag::kNonBlocking).IsOk()); in TEST_F()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/
Dtask.h52 enum class WaitFlag : int { kBlocking, kNonBlocking }; enumerator
Dtask.cc148 } else if (blocking == WaitFlag::kNonBlocking) { in Join()
Dtask_manager.cc331 return (join_all(Task::WaitFlag::kNonBlocking)); in DoServiceStop()
DREADME.md76 enum class WaitFlag : int { kBlocking, kNonBlocking };
85 The non-blocking version (kNonBlocking) of Join allows us to force the thread to return if timed ou…
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_grpc_client.cc69 RETURN_IF_NOT_OK(vg_.join_all(Task::WaitFlag::kNonBlocking)); in DoServiceStop()