Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for stopAsync (0.11 sec)

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

        service.startAsync().awaitRunning();
        enterRun.await(); // to avoid stopping the service until run() is invoked
    
        service.stopAsync();
        service.stopAsync();
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
    
        executionThread.join();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

        assertThat(service.transitionStates).containsExactly(Service.State.STARTING);
      }
    
      public void testStop_withoutStart() {
        TestService service = new TestService();
        service.stopAsync().awaitTerminated();
        assertEquals(0, service.startUpCalled);
        assertEquals(0, service.shutDownCalled);
        assertEquals(Service.State.TERMINATED, service.state());
        assertThat(service.transitionStates).isEmpty();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        service.startAsync().awaitRunning();
        enterRun.await(); // to avoid stopping the service until run() is invoked
    
        service.stopAsync();
        service.stopAsync();
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
    
        executionThread.join();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

        assertThat(service.transitionStates).containsExactly(Service.State.STARTING);
      }
    
      public void testStop_withoutStart() {
        TestService service = new TestService();
        service.stopAsync().awaitTerminated();
        assertEquals(0, service.startUpCalled);
        assertEquals(0, service.shutDownCalled);
        assertEquals(Service.State.TERMINATED, service.state());
        assertThat(service.transitionStates).isEmpty();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

            new Thread() {
              @Override
              public void run() {
                manager.stopAsync().awaitStopped();
              }
            };
        stoppingThread.start();
        // this should be super fast since the only non-stopped service is a NoOpService
        stoppingThread.join(1000);
        assertFalse("stopAsync has deadlocked!.", stoppingThread.isAlive());
        failLeave.countDown(); // release the background thread
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
       * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is
       * called multiple times.
       *
       * <p>If {@link #stopAsync} is called on a {@link State#STARTING} service, this method is not
       * invoked immediately. Instead, it will be deferred until after the service is {@link
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/Service.java

    import java.util.concurrent.Executor;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    /**
     * An object with an operational state, plus asynchronous {@link #startAsync()} and {@link
     * #stopAsync()} lifecycle methods to transition between states. Example services include
     * webservers, RPC servers and timers.
     *
     * <p>The normal lifecycle of a service is:
     *
     * <ul>
     *   <li>{@linkplain State#NEW NEW} -&gt;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractService.java

       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
       * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is
       * called multiple times.
       *
       * <p>If {@link #stopAsync} is called on a {@link State#STARTING} service, this method is not
       * invoked immediately. Instead, it will be deferred until after the service is {@link
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Service.java

    import java.util.concurrent.Executor;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    /**
     * An object with an operational state, plus asynchronous {@link #startAsync()} and {@link
     * #stopAsync()} lifecycle methods to transition between states. Example services include
     * webservers, RPC servers and timers.
     *
     * <p>The normal lifecycle of a service is:
     *
     * <ul>
     *   <li>{@linkplain State#NEW NEW} -&gt;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      @Override
      public final Service startAsync() {
        delegate.startAsync();
        return this;
      }
    
      /** @since 15.0 */
      @CanIgnoreReturnValue
      @Override
      public final Service stopAsync() {
        delegate.stopAsync();
        return this;
      }
    
      /** @since 15.0 */
      @Override
      public final void awaitRunning() {
        delegate.awaitRunning();
      }
    
      /** @since 28.0 */
      @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top