Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for awaitRunning (0.07 sec)

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

            thrownByExecutionThread);
      }
    
      public void testServiceStartStop() throws Exception {
        WaitOnRunService service = new WaitOnRunService();
        assertFalse(service.startUpCalled);
    
        service.startAsync().awaitRunning();
        assertTrue(service.startUpCalled);
        assertEquals(Service.State.RUNNING, service.state());
    
        enterRun.await(); // to avoid stopping the service until run() is invoked
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AbstractService.java

      }
    
      @Override
      public final void awaitRunning() {
        monitor.enterWhenUninterruptibly(hasReachedRunning);
        try {
          checkCurrentState(RUNNING);
        } finally {
          monitor.leave();
        }
      }
    
      /**
       * @since 28.0
       */
      @Override
      public final void awaitRunning(Duration timeout) throws TimeoutException {
        Service.super.awaitRunning(timeout);
      }
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/Service.java

       *     State#TERMINATED} when this method is called then this will throw an IllegalStateException.
       * @since 28.0
       */
      default void awaitRunning(Duration timeout) throws TimeoutException {
        awaitRunning(toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
       * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

       */
      @Override
      public final void awaitRunning() {
        delegate.awaitRunning();
      }
    
      /**
       * @since 28.0
       */
      @Override
      public final void awaitRunning(Duration timeout) throws TimeoutException {
        Service.super.awaitRunning(timeout);
      }
    
      /**
       * @since 15.0
       */
      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Service.java

       *     enter the {@link State#RUNNING} state. e.g. if the {@code state} is {@code
       *     State#TERMINATED} when this method is called then this will throw an IllegalStateException.
       * @since 15.0
       */
      void awaitRunning();
    
      /**
       * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more
       * than the given time.
       *
       * @param timeout the maximum time to wait
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

                return delegate.stopAsync();
              }
    
              @Override
              public final void awaitRunning() {
                delegate.awaitRunning();
              }
    
              @Override
              public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
                delegate.awaitRunning(timeout, unit);
              }
    
              @Override
              public final void awaitTerminated() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 20:34:52 UTC 2025
    - 25.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        return this;
      }
    
      /**
       * @since 15.0
       */
      @Override
      public final void awaitRunning() {
        delegate.awaitRunning();
      }
    
      /**
       * @since 15.0
       */
      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
        delegate.awaitRunning(timeout, unit);
      }
    
      /**
       * @since 15.0
       */
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractService.java

          }
        }
        return this;
      }
    
      @Override
      public final void awaitRunning() {
        monitor.enterWhenUninterruptibly(hasReachedRunning);
        try {
          checkCurrentState(RUNNING);
        } finally {
          monitor.leave();
        }
      }
    
      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
Back to top