- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for requestStop (0.93 sec)
-
tensorflow/cc/training/coordinator.h
/// Returns true iff all the registered runners have been stopped. bool AllRunnersStopped(); /// Requests all running threads to stop. Status RequestStop(); /// Returns true if its RequestStop() has been called. bool ShouldStop(); /// Joins all threads, returns OK or the first reported and unexpected status. Status Join();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 12 08:49:52 UTC 2023 - 4.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/async/ServiceLifecycleTest.groovy
then: instant.action1Done > instant.action2Done } def "can stop multiple times"() { when: lifecycle.stop() lifecycle.stop() lifecycle.requestStop() lifecycle.requestStop() lifecycle.stop() then: noExceptionThrown() } def "throws exception when attempting to use service after it has stopped"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 6.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonStateCoordinatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 16.3K bytes - Viewed (0) -
tensorflow/cc/training/coordinator_test.cc
std::bind(&WaitForStopThread, &coord, &about_to_wait, &done)); about_to_wait.WaitForNotification(); Env::Default()->SleepForMicroseconds(1000 * 1000); EXPECT_FALSE(done.HasBeenNotified()); TF_EXPECT_OK(coord.RequestStop()); done.WaitForNotification(); EXPECT_TRUE(coord.ShouldStop()); } class MockQueueRunner : public RunnerInterface { public: explicit MockQueueRunner(Coordinator* coord) { coord_ = coord;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Mar 23 09:10:43 UTC 2023 - 6.9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/AsyncDispatchTest.groovy
} def 'can request stop from multiple threads'() { when: dispatch.dispatchTo(target1) parallel.start { dispatch.requestStop() } parallel.start { dispatch.requestStop() } parallel.waitForAll() dispatch.stop() then: noExceptionThrown() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 6.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/RequestStopIfSingleUsedDaemon.java
LOGGER.debug("Requesting daemon stop after processing {}", execution.getCommand()); // Does not take effect until after execution has completed execution.getDaemonStateControl().requestStop(""); } execution.proceed(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/TcpIncomingConnector.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 5.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
def dispatcher = hub.getOutgoing("channel", String) dispatcher.dispatch("message 1") dispatcher.dispatch("message 2") when: operation.requestStop { hub.requestStop() } hub.stop() then: 1 * listener.messageDiscarded("message 1") >> { thread.block() instant.message1Handled }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/DefaultAsyncConsumerActionExecutor.java
@Override public void stop() { CompositeStoppable.stoppable(lifecycle, executor, actionExecutor).stop(); } @Override public void disconnect() { lifecycle.requestStop(); executor.requestStop(); actionExecutor.disconnect(); } @Override public <T> void run(final ConsumerAction<? extends T> action, final ResultHandlerVersion1<? super T> handler) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 2.8K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/AbstractManagedExecutor.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 3.4K bytes - Viewed (0)