Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 310 for stopping (0.2 sec)

  1. android/guava/src/com/google/common/util/concurrent/AbstractService.java

            @Override
            public String toString() {
              return "running()";
            }
          };
      private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_STARTING_EVENT =
          stoppingEvent(STARTING);
      private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_RUNNING_EVENT =
          stoppingEvent(RUNNING);
    
      private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_NEW_EVENT =
          terminatedEvent(NEW);
    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)
  2. 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) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 1.9K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        assertFalse(service.isRunning());
        assertTrue(service.doStartCalled);
    
        service.stopAsync();
        assertEquals(State.STOPPING, service.state());
        assertFalse(service.isRunning());
        assertFalse(service.doStopCalled);
    
        service.notifyStarted();
        assertEquals(State.STOPPING, service.state());
        assertFalse(service.isRunning());
        assertTrue(service.doStopCalled);
    
        service.notifyStopped();
    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)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        assertFalse(service.isRunning());
        assertTrue(service.doStartCalled);
    
        service.stopAsync();
        assertEquals(State.STOPPING, service.state());
        assertFalse(service.isRunning());
        assertFalse(service.doStopCalled);
    
        service.notifyStarted();
        assertEquals(State.STOPPING, service.state());
        assertFalse(service.isRunning());
        assertTrue(service.doStopCalled);
    
        service.notifyStopped();
    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)
  5. 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) {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 1.9K bytes
    - Viewed (0)
  6. 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) {}
    
        /**
    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)
  7. 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();
      }
    
    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)
  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() {
        final Exception exception = new Exception("deliberate");
        TestService service =
            new TestService() {
              @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  9. 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() {}
    
      /**
    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)
  10. 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();
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12.7K bytes
    - Viewed (0)
Back to top