- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RealRun (0.11 sec)
-
tensorflow/cc/training/queue_runner.cc
return Start(session, wait_for_ms); } void QueueRunner::Stop(Session* sess) { if (coord_ != nullptr) { coord_->WaitForStop(); } if (!cancel_op_name_.empty()) { UpdateStatus(RealRun(sess, cancel_op_name_, false)); } stopped_ = true; } Status QueueRunner::Join() { thread_pool_.reset(); mutex_lock l(mu_); return status_; }
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
static_cast<int>(status.code())) > 0; } bool IsRunning() const override { return !stopped_; } void SetRunArgumentsAndCostGraph(const RunOptions& run_options); Status RealRun(Session* sess, const string& op, bool update_costs); string queue_name_; std::vector<string> enqueue_op_names_; string close_op_name_; string cancel_op_name_;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 31 18:27:00 UTC 2022 - 5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java
final AtomicDouble at = new AtomicDouble(1.0); Thread t = newStartedThread( new CheckedRunnable() { @Override public void realRun() { while (!at.compareAndSet(2.0, 3.0)) { Thread.yield(); } } }); assertTrue(at.compareAndSet(1.0, 2.0));
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 6.9K bytes - Viewed (0)