- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for notifyStopped (0.23 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
assertTrue(service.isRunning()); assertFalse(service.doStopCalled); service.notifyStopped(); assertEquals(State.TERMINATED, service.state()); assertFalse(service.isRunning()); assertFalse(service.doStopCalled); } /** * The user of this service should call {@link #notifyStarted} and {@link #notifyStopped} after * calling {@link #startAsync} and {@link #stopAsync}. */
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-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
assertTrue(service.isRunning()); assertFalse(service.doStopCalled); service.notifyStopped(); assertEquals(State.TERMINATED, service.state()); assertFalse(service.isRunning()); assertFalse(service.doStopCalled); } /** * The user of this service should call {@link #notifyStarted} and {@link #notifyStopped} after * calling {@link #startAsync} and {@link #stopAsync}. */
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) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
@Override protected void doStart() { notifyFailed(new IllegalStateException("start failure")); notifyStopped(); // This will be a no-op. } @Override protected void doStop() { notifyStopped(); } }; final ServiceManager manager = new ServiceManager(asList(a)); manager.startAsync();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
@Override protected void doStart() { notifyFailed(new IllegalStateException("start failure")); notifyStopped(); // This will be a no-op. } @Override protected void doStop() { notifyStopped(); } }; final ServiceManager manager = new ServiceManager(asList(a)); manager.startAsync();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
* State#STARTING}, or {@link State#RUNNING}. */ protected final void notifyStopped() { monitor.enter(); try { State previous = state(); switch (previous) { case NEW: case TERMINATED: case FAILED: throw new IllegalStateException("Cannot notifyStopped() when the service is " + previous); case RUNNING: case STARTING:
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/src/com/google/common/util/concurrent/AbstractIdleService.java
protected final void doStop() { MoreExecutors.renamingDecorator(executor(), threadNameSupplier) .execute( () -> { try { shutDown(); notifyStopped(); } catch (Throwable t) { restoreInterruptIfIsInterruptedException(t); notifyFailed(t); } }); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 17 13:59:28 GMT 2023 - 5.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
} notifyFailed(t); return; } } shutDown(); notifyStopped(); } catch (Throwable t) { restoreInterruptIfIsInterruptedException(t); notifyFailed(t); } }); } @Override
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) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
return; } shutDown(); } finally { lock.unlock(); } notifyStopped(); } catch (Throwable t) { restoreInterruptIfIsInterruptedException(t); notifyFailed(t); } }); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
*/ private static final class NoOpService extends AbstractService { @Override protected void doStart() { notifyStarted(); } @Override protected void doStop() { notifyStopped(); } } /** This is never thrown but only used for logging. */ private static final class EmptyServiceManagerWarning extends Throwable {}
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0)