- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for BlockingCounter (0.14 sec)
-
tensorflow/cc/training/coordinator_test.cc
Notification* start = nullptr) { thread_pool_->Schedule( std::bind(&MockQueueRunner::CountThread, this, counter, until, start)); } void StartSettingStatus(const Status& status, BlockingCounter* counter, Notification* start) { thread_pool_->Schedule(std::bind(&MockQueueRunner::SetStatusThread, this, status, counter, start)); }
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/queue_runner.cc
SetRunArgumentsAndCostGraph(run_options); return Start(sess, 0); } Status QueueRunner::Start(Session* sess, int wait_for) { counter_.reset(new BlockingCounter(runs_)); for (const string& enqueue_op : enqueue_op_names_) { thread_pool_->Schedule( std::bind(&QueueRunner::Run, this, sess, enqueue_op)); } if (coord_) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.h
std::unique_ptr<thread::ThreadPool> thread_pool_; mutex mu_; int runs_ = 0; Status status_ TF_GUARDED_BY(mu_); Status enqueue_status_ TF_GUARDED_BY(mu_); std::unique_ptr<BlockingCounter> counter_; Coordinator* coord_; std::atomic<bool> stopped_; mutex cb_mu_; std::vector<std::function<void(Status)>> callbacks_; mutable std::unique_ptr<mutex> cg_mu_;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 31 18:27:00 UTC 2022 - 5K bytes - Viewed (0)