- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 252 for skipping (0.06 sec)
-
guava-tests/test/com/google/common/util/concurrent/ServiceTest.java
assertLessThan(NEW, TERMINATED); assertLessThan(STARTING, RUNNING); assertLessThan(STARTING, STOPPING); assertLessThan(STARTING, FAILED); assertLessThan(RUNNING, STOPPING); assertLessThan(RUNNING, FAILED); assertLessThan(STOPPING, FAILED); assertLessThan(STOPPING, TERMINATED); } private static <T extends Comparable<? super T>> void assertLessThan(T a, T b) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
src/etc/header-definition.xml
<?xml version="1.0" encoding="UTF-8"?> <additionalHeaders> <javadoc_style> <firstLine>/*</firstLine> <beforeEachLine> * </beforeEachLine> <endLine> */</endLine> <!--skipLine></skipLine--> <firstLineDetectionPattern>(\s|\t)*/\*.*$</firstLineDetectionPattern> <lastLineDetectionPattern>.*\*/(\s|\t)*$</lastLineDetectionPattern> <allowBlankLines>false</allowBlankLines>
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sun Sep 15 12:48:40 UTC 2013 - 509 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) {} /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 10.7K 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
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 7.5K bytes - Viewed (0) -
cmd/signals.go
p.Stop() } if success { os.Exit(0) } os.Exit(1) } stopProcess := func() bool { shutdownHealMRFWithTimeout() // this can take time sometimes, it needs to be executed // before stopping s3 operations // send signal to various go-routines that they need to quit. cancelGlobalContext() if httpServer := newHTTPServerFn(); httpServer != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 04 17:02:39 UTC 2024 - 3.2K bytes - Viewed (0) -
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) {} /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K 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
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 7.5K 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(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 12.7K bytes - Viewed (0) -
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() {} /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 13:00:28 UTC 2024 - 7.3K bytes - Viewed (0)