- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 283 for stopping (0.16 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractService.java
@Override public String toString() { return "running()"; } }; private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_STARTING_EVENT = stoppingEvent(STARTING); private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_RUNNING_EVENT = stoppingEvent(RUNNING); private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_NEW_EVENT = terminatedEvent(NEW);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 20.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
assertFalse(service.isRunning()); assertTrue(service.doStartCalled); service.stopAsync(); assertEquals(State.STOPPING, service.state()); assertFalse(service.isRunning()); assertFalse(service.doStopCalled); service.notifyStarted(); assertEquals(State.STOPPING, service.state()); assertFalse(service.isRunning()); assertTrue(service.doStopCalled); service.notifyStopped();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 29.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
assertFalse(service.isRunning()); assertTrue(service.doStartCalled); service.stopAsync(); assertEquals(State.STOPPING, service.state()); assertFalse(service.isRunning()); assertFalse(service.doStopCalled); service.notifyStarted(); assertEquals(State.STOPPING, service.state()); assertFalse(service.isRunning()); assertTrue(service.doStopCalled); service.notifyStopped();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 29.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* Called when the service transitions to the {@linkplain State#STOPPING STOPPING} state. The * only valid values for {@code from} are {@linkplain State#STARTING STARTING} or {@linkplain * State#RUNNING RUNNING}. This occurs when {@link Service#stopAsync} is called. * * @param from The previous state that is being transitioned from. */ public void stopping(State from) {} /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 10.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
assertFalse(service.startUpCalled); service.startAsync().awaitRunning(); assertTrue(service.startUpCalled); assertEquals(Service.State.RUNNING, service.state()); enterRun.await(); // to avoid stopping the service until run() is invoked service.stopAsync().awaitTerminated(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); executionThread.join(); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
assertFalse(service.startUpCalled); service.startAsync().awaitRunning(); assertTrue(service.startUpCalled); assertEquals(Service.State.RUNNING, service.state()); enterRun.await(); // to avoid stopping the service until run() is invoked service.stopAsync().awaitTerminated(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); executionThread.join(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
assertEquals(1, service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); assertThat(service.transitionStates) .containsExactly(Service.State.STARTING, Service.State.STOPPING) .inOrder(); } public void testStop_failed() { final Exception exception = new Exception("deliberate"); TestService service = new TestService() { @Override
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
assertEquals(1, service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); assertThat(service.transitionStates) .containsExactly(Service.State.STARTING, Service.State.STOPPING) .inOrder(); } public void testStop_failed() { final Exception exception = new Exception("deliberate"); TestService service = new TestService() { @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* blocks, it can prevent this service from changing state. If you need to performing a blocking * operation in order to trigger shutdown, consider instead registering a listener and * implementing {@code stopping}. Note, however, that {@code stopping} does not run at exactly the * same times as {@code triggerShutdown}. */ protected void triggerShutdown() {} /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 7.6K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
return layout, err } } } var stopping bool var singleNode bool var eps []string for i := 0; ; i++ { for _, node := range endpointsList { if node.nodeName == "" { singleNode = true } if len(node.disks) <= i { stopping = true continue } if stopping { return layout, errors.New("number of disks per node does not match")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0)