- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RegisterRunner (0.13 sec)
-
tensorflow/cc/training/coordinator_test.cc
std::unique_ptr<MockQueueRunner> qr1(new MockQueueRunner(&coord)); qr1->StartCounting(&counter, 100); TF_ASSERT_OK(coord.RegisterRunner(std::move(qr1))); std::unique_ptr<MockQueueRunner> qr2(new MockQueueRunner(&coord)); qr2->StartCounting(&counter, 100); TF_ASSERT_OK(coord.RegisterRunner(std::move(qr2))); // Wait until the counting has started while (counter.load() == 0) ;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Mar 23 09:10:43 UTC 2023 - 6.9K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.h
/// thread or any client. /// Usage, in the client: /// Coordinator coord; /// std::unique_ptr<QueueRunner> qr(&coord, ...); /// qr.Start(session); /// coord.RegisterRunner(std::move(qr)); /// /// do some work /// TF_CHECK_OK(coord.Join()); /// In each thread of QueueRunner, the coordinator needs to be used as: /// void Run() { /// while (!coord->ShouldStop()) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 12 08:49:52 UTC 2023 - 4.4K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.cc
clean_stop_errors_.insert(static_cast<int>(code)); } } } Coordinator::~Coordinator() { RequestStop().IgnoreError(); Join().IgnoreError(); } Status Coordinator::RegisterRunner(std::unique_ptr<RunnerInterface> runner) { { mutex_lock l(mu_); if (should_stop_) { return Status(absl::StatusCode::kFailedPrecondition, "The coordinator has been stopped."); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 3.2K bytes - Viewed (0)