- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for RegisterRunner (0.16 sec)
-
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)