- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for RealRun (0.32 sec)
-
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
protected abstract void realRun() throws Throwable; @Override public final void run() { try { realRun(); } catch (Throwable t) { threadUnexpectedException(t); } } } public abstract class RunnableShouldThrow implements Runnable { protected abstract void realRun() throws Throwable; final Class<?> exceptionClass;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
protected abstract void realRun() throws Throwable; @Override public final void run() { try { realRun(); } catch (Throwable t) { threadUnexpectedException(t); } } } public abstract class RunnableShouldThrow implements Runnable { protected abstract void realRun() throws Throwable; final Class<?> exceptionClass;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
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) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java
final AtomicDoubleArray a = new AtomicDoubleArray(1); a.set(0, 1.0); Thread t = newStartedThread( new CheckedRunnable() { @Override public void realRun() { while (!a.compareAndSet(0, 2.0, 3.0)) { Thread.yield(); } } }); assertTrue(a.compareAndSet(0, 1.0, 2.0));
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 10.5K 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) -
guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java
final AtomicDoubleArray a = new AtomicDoubleArray(1); a.set(0, 1.0); Thread t = newStartedThread( new CheckedRunnable() { @Override public void realRun() { while (!a.compareAndSet(0, 2.0, 3.0)) { Thread.yield(); } } }); assertTrue(a.compareAndSet(0, 1.0, 2.0));
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 14.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) -
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: Wed Feb 09 22:57:07 UTC 2022 - 10.2K bytes - Viewed (0)