Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for notifyStopped (0.2 sec)

  1. 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)
  2. 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 Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
  3. 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 Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top