Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for notifyStarted (0.09 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 25.6K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java

        protected final void doStart() {
          renamingDecorator(executor(), threadNameSupplier)
              .execute(
                  () -> {
                    try {
                      startUp();
                      notifyStarted();
                    } catch (Throwable t) {
                      restoreInterruptIfIsInterruptedException(t);
                      notifyFailed(t);
                    }
                  });
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  3. 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()) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       * logging statements.
       */
      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. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 33.2K bytes
    - Click Count (1)
  5. 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) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
Back to Top