Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for notifyStarted (0.06 sec)

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

     * @author Chris Nokleberg
     */
    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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

              Executor executor = MoreExecutors.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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  3. 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. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  4. 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. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  5. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
Back to top