- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for notifyStarted (0.14 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
Executor executor = renamingDecorator(executor(), () -> serviceName()); executor.execute( () -> { try { startUp(); notifyStarted(); // If stopAsync() is called while starting we may be in the STOPPING state in // which case we should skip right down to shutdown. if (isRunning()) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
* @author Chris Nokleberg */ @NullUnmarked public class ServiceManagerTest extends TestCase { private static class NoOpService extends AbstractService { @Override protected void doStart() { notifyStarted(); } @Override protected void doStop() { notifyStopped(); } } /* * A NoOp service that will delay the startup and shutdown notification for a configurable amount
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 20:34:52 UTC 2025 - 25.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
Executor executor = renamingDecorator(executor(), () -> serviceName()); executor.execute( () -> { try { startUp(); notifyStarted(); // If stopAsync() is called while starting we may be in the STOPPING state in // which case we should skip right down to shutdown. if (isRunning()) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* assignment above. */ requireNonNull(executorService); runningTask = scheduler().schedule(delegate, executorService, task); notifyStarted(); } catch (Throwable t) { restoreInterruptIfIsInterruptedException(t); notifyFailed(t); if (runningTask != null) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* assignment above. */ requireNonNull(executorService); runningTask = scheduler().schedule(delegate, executorService, task); notifyStarted(); } catch (Throwable t) { restoreInterruptIfIsInterruptedException(t); notifyFailed(t); if (runningTask != null) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0)