- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for should_stop_ (0.34 sec)
-
tensorflow/cc/training/coordinator.cc
} Status Coordinator::RequestStop() { mutex_lock l(mu_); if (should_stop_) { return Status(absl::StatusCode::kFailedPrecondition, "The Coordinator is not running."); } should_stop_ = true; wait_for_stop_.notify_all(); return absl::OkStatus(); } bool Coordinator::ShouldStop() { mutex_lock l(mu_); return should_stop_; } Status Coordinator::Join() {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 3.2K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.h
Status ExportCostGraph(CostGraphDef* cost_graph) const; private: std::unordered_set<int> clean_stop_errors_; condition_variable wait_for_stop_; mutex mu_; bool should_stop_ TF_GUARDED_BY(mu_); mutex status_lock_; Status status_ TF_GUARDED_BY(status_lock_); mutable mutex runners_lock_; std::vector<std::unique_ptr<RunnerInterface>> runners_
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 12 08:49:52 UTC 2023 - 4.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
Thread.sleep(everyMillis); } catch (InterruptedException e) { // ok. just stop sleeping. } if (shouldStop) { break; } interruptee.interrupt(); } } void stopInterrupting() { shouldStop = true; } } /** Interrupts the current thread after sleeping for the specified delay. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/LogToClient.java
private final Queue<OutputEvent> eventQueue = new ConcurrentLinkedQueue<OutputEvent>(); private final DaemonConnection connection; private final OutputEventListener listener; private volatile boolean shouldStop; private boolean unableToSend; private AsynchronousLogDispatcher(DaemonConnection conn, final LogLevel buildLogLevel) { super("Asynchronous log dispatcher for " + conn);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 6.1K bytes - Viewed (0) -
src/internal/fuzz/minimize.go
for n := 1024; n != 0; n /= 2 { for len(v) > n { if shouldStop() { return } candidate := v[:len(v)-n] if !try(candidate) { break } // Set v to the new value to continue iterating. v = candidate } } // Then, try to remove each individual byte. for i := 0; i < len(v)-1; i++ { if shouldStop() { return } candidate := tmp[:len(v)-1]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 07 21:15:51 UTC 2021 - 2.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
Thread.sleep(everyMillis); } catch (InterruptedException e) { // ok. just stop sleeping. } if (shouldStop) { break; } interruptee.interrupt(); } } void stopInterrupting() { shouldStop = true; } } /** Interrupts the current thread after sleeping for the specified delay. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.4K bytes - Viewed (0) -
tensorflow/cc/training/coordinator_test.cc
Notification* done) { about_to_wait->Notify(); coord->WaitForStop(); done->Notify(); } TEST(CoordinatorTest, TestStopAndWaitOnStop) { Coordinator coord; EXPECT_EQ(coord.ShouldStop(), false); Notification about_to_wait; Notification done; Env::Default()->SchedClosure( std::bind(&WaitForStopThread, &coord, &about_to_wait, &done)); about_to_wait.WaitForNotification();
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
cb(status); } } void QueueRunner::Run(Session* sess, const string& enqueue_op) { bool first_iteration = true; Status status; while (status.ok()) { if (coord_ && coord_->ShouldStop()) { break; } status = RealRun(sess, enqueue_op, true); if (first_iteration) { if (!status.ok()) { mutex_lock l(mu_); enqueue_status_ = status; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
src/internal/fuzz/worker.go
keepCoverage := args.KeepCoverage memBytes := mem.valueRef() bPtr := &memBytes count := &mem.header().count shouldStop := func() bool { return ctx.Err() != nil || (args.Limit > 0 && *count >= args.Limit) } if shouldStop() { return false, nil } // Check that the original value preserves coverage or causes an error.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 37.7K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
func (p *pageAlloc) scavenge(nbytes uintptr, shouldStop func() bool, force bool) uintptr { released := uintptr(0) for released < nbytes { ci, pageIdx := p.scav.index.find(force) if ci == 0 { break } systemstack(func() { released += p.scavengeOne(ci, pageIdx, nbytes-released) }) if shouldStop != nil && shouldStop() { break } } return released }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0)