Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 283 for stopping (0.04 sec)

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

        assertLessThan(NEW, TERMINATED);
    
        assertLessThan(STARTING, RUNNING);
        assertLessThan(STARTING, STOPPING);
        assertLessThan(STARTING, FAILED);
    
        assertLessThan(RUNNING, STOPPING);
        assertLessThan(RUNNING, FAILED);
    
        assertLessThan(STOPPING, FAILED);
        assertLessThan(STOPPING, TERMINATED);
      }
    
      private static <T extends Comparable<? super T>> void assertLessThan(T a, T b) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractService.java

        return new ListenerCallQueue.Event<Listener>() {
          @Override
          public void call(Listener listener) {
            listener.stopping(from);
          }
    
          @Override
          public String toString() {
            return "stopping({from = " + from + "})";
          }
        };
      }
    
      private final Monitor monitor = new Monitor();
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractService.java

        return new ListenerCallQueue.Event<Listener>() {
          @Override
          public void call(Listener listener) {
            listener.stopping(from);
          }
    
          @Override
          public String toString() {
            return "stopping({from = " + from + "})";
          }
        };
      }
    
      private final Monitor monitor = new Monitor();
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Service.java

         * Called when the service transitions to the {@linkplain State#STOPPING STOPPING} state. The
         * only valid values for {@code from} are {@linkplain State#STARTING STARTING} or {@linkplain
         * State#RUNNING RUNNING}. This occurs when {@link Service#stopAsync} is called.
         *
         * @param from The previous state that is being transitioned from.
         */
        public void stopping(State from) {}
    
        /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        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
    
        service.stopAsync().awaitTerminated();
        assertTrue(service.shutDownCalled);
        assertEquals(Service.State.TERMINATED, service.state());
        executionThread.join();
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

       * blocks, it can prevent this service from changing state. If you need to performing a blocking
       * operation in order to trigger shutdown, consider instead registering a listener and
       * implementing {@code stopping}. Note, however, that {@code stopping} does not run at exactly the
       * same times as {@code triggerShutdown}.
       */
      protected void triggerShutdown() {}
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Service.java

         * Called when the service transitions to the {@linkplain State#STOPPING STOPPING} state. The
         * only valid values for {@code from} are {@linkplain State#STARTING STARTING} or {@linkplain
         * State#RUNNING RUNNING}. This occurs when {@link Service#stopAsync} is called.
         *
         * @param from The previous state that is being transitioned from.
         */
        public void stopping(State from) {}
    
        /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

        assertEquals(1, service.shutDownCalled);
        assertEquals(Service.State.TERMINATED, service.state());
        assertThat(service.transitionStates)
            .containsExactly(Service.State.STARTING, Service.State.STOPPING)
            .inOrder();
      }
    
      public void testStop_failed() {
        Exception exception = new Exception("deliberate");
        TestService service =
            new TestService() {
              @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        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
    
        service.stopAsync().awaitTerminated();
        assertTrue(service.shutDownCalled);
        assertEquals(Service.State.TERMINATED, service.state());
        executionThread.join();
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

       * blocks, it can prevent this service from changing state. If you need to performing a blocking
       * operation in order to trigger shutdown, consider instead registering a listener and
       * implementing {@code stopping}. Note, however, that {@code stopping} does not run at exactly the
       * same times as {@code triggerShutdown}.
       */
      protected void triggerShutdown() {}
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
Back to top