Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 104 for startup (0.19 sec)

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

        final CountDownLatch started = new CountDownLatch(1);
        FakeService service =
            new FakeService() {
              @Override
              protected void startUp() throws Exception {
                super.startUp();
                started.await();
              }
            };
        service.startAsync();
        service.stopAsync();
        started.countDown();
        service.awaitTerminated();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        assertFalse(listener.healthyCalled);
      }
    
      /**
       * This covers a bug where if a listener was installed that would stop the manager if any service
       * fails and something failed during startup before service.start was called on all the services,
       * then awaitStopped would deadlock due to an IllegalStateException that was thrown when trying to
       * stop the timer(!).
       */
    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)
  3. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * Base class for services that can implement {@link #startUp} and {@link #shutDown} but while in
     * the "running" state need to perform a periodic task. Subclasses can implement {@link #startUp},
     * {@link #shutDown} and also a {@link #runOneIteration} method that will be executed periodically.
     *
     * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run
    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)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        final CountDownLatch started = new CountDownLatch(1);
        FakeService service =
            new FakeService() {
              @Override
              protected void startUp() throws Exception {
                super.startUp();
                started.await();
              }
            };
        service.startAsync();
        service.stopAsync();
        started.countDown();
        service.awaitTerminated();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

      }
    
      public void testExecutorOnlyCalledOnce() throws Exception {
        TestService service = new TestService();
        service.startAsync().awaitRunning();
        // It should be called once during startup.
        assertEquals(1, service.numberOfTimesExecutorCalled.get());
        for (int i = 1; i < 10; i++) {
          service.runFirstBarrier.await();
          assertEquals(i, service.numberOfTimesRunCalled.get());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      protected AbstractService() {}
    
      /**
       * This method is called by {@link #startAsync} to initiate service startup. The invocation of
       * this method should cause a call to {@link #notifyStarted()}, either during this method's run,
       * or after it has returned. If startup fails, the invocation should cause a call to {@link
       * #notifyFailed(Throwable)} instead.
       *
    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)
  7. guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        assertFalse(listener.healthyCalled);
      }
    
      /**
       * This covers a bug where if a listener was installed that would stop the manager if any service
       * fails and something failed during startup before service.start was called on all the services,
       * then awaitStopped would deadlock due to an IllegalStateException that was thrown when trying to
       * stop the timer(!).
       */
    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)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

      }
    
      public void testExecutorOnlyCalledOnce() throws Exception {
        TestService service = new TestService();
        service.startAsync().awaitRunning();
        // It should be called once during startup.
        assertEquals(1, service.numberOfTimesExecutorCalled.get());
        for (int i = 1; i < 10; i++) {
          service.runFirstBarrier.await();
          assertEquals(i, service.numberOfTimesRunCalled.get());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

        return state.servicesByState();
      }
    
      /**
       * Returns the service load times. This value will only return startup times for services that
       * have finished starting.
       *
       * @return Map of services and their corresponding startup time in millis, the map entries will be
       *     ordered by startup time.
       */
      public ImmutableMap<Service, Long> startupTimes() {
        return state.startupTimes();
      }
    
    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)
  10. android/guava/src/com/google/common/util/concurrent/Service.java

    @DoNotMock("Create an AbstractIdleService")
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    public interface Service {
      /**
       * If the service state is {@link State#NEW}, this initiates service startup and returns
       * immediately. A stopped service may not be restarted.
       *
       * @return this
       * @throws IllegalStateException if the service is not {@link State#NEW}
       * @since 15.0
       */
      @CanIgnoreReturnValue
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 10.7K bytes
    - Viewed (0)
Back to top