Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 75 for terminated (0.21 sec)

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

            }
          }
          assertNotSame(from, service.state());
        }
    
        @Override
        public synchronized void terminated(State from) {
          assertEquals(from, Iterables.getLast(stateHistory, State.NEW));
          stateHistory.add(State.TERMINATED);
          assertEquals(State.TERMINATED, service.state());
          if (from == State.NEW) {
            try {
              service.awaitRunning();
              fail();
    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)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

            }
          }
          assertNotSame(from, service.state());
        }
    
        @Override
        public synchronized void terminated(State from) {
          assertEquals(from, Iterables.getLast(stateHistory, State.NEW));
          stateHistory.add(State.TERMINATED);
          assertEquals(State.TERMINATED, service.state());
          if (from == State.NEW) {
            try {
              service.awaitRunning();
              fail();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Service.java

         */
        public void stopping(State from) {}
    
        /**
         * Called when the service transitions to the {@linkplain State#TERMINATED TERMINATED} state.
         * The {@linkplain State#TERMINATED TERMINATED} state is a terminal state in the transition
         * diagram. Therefore, if this method is called, no other methods will be called on the {@link
         * Listener}.
         *
    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)
  4. guava-tests/test/com/google/common/util/concurrent/ServiceTest.java

        assertLessThan(NEW, STARTING);
        assertLessThan(NEW, TERMINATED);
    
        assertLessThan(STARTING, RUNNING);
        assertLessThan(STARTING, STOPPING);
        assertLessThan(STARTING, FAILED);
    
        assertLessThan(RUNNING, STOPPING);
        assertLessThan(RUNNING, FAILED);
    
        assertLessThan(STOPPING, FAILED);
        assertLessThan(STOPPING, TERMINATED);
      }
    
    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)
  5. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

                    logger.error("IndexUpdater is terminated.", e);
                } else if (logger.isInfoEnabled()) {
                    logger.info("IndexUpdater is terminated.");
                }
                forceStop();
            } catch (final Throwable t) {
                if (ComponentUtil.available()) {
                    logger.error("IndexUpdater is terminated.", t);
                } else if (logger.isDebugEnabled()) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 24.2K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        service.stopAsync();
        service.stopAsync();
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
    
        executionThread.join();
      }
    
      public void testServiceExitingOnItsOwn() throws Exception {
    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)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

        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();
      }
    
      public void testStop_afterStart() {
        TestService service = new TestService();
        service.startAsync().awaitRunning();
    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)
  8. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        assertTrue(listener.healthyCalled);
        assertFalse(listener.stoppedCalled);
        assertTrue(listener.failedServices.isEmpty());
        manager.stopAsync().awaitStopped();
        assertState(manager, Service.State.TERMINATED, a, b);
        assertFalse(manager.isHealthy());
        assertTrue(listener.stoppedCalled);
        assertTrue(listener.failedServices.isEmpty());
      }
    
      public void testFailStart() throws Exception {
    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)
  9. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

         * State#FAILED fail}/{@linkplain State#TERMINATED terminate} before all other services have
         * started {@linkplain State#RUNNING running} then this method will not be called.
         */
        public void healthy() {}
    
        /**
         * Called when the all of the component services have reached a terminal state, either
         * {@linkplain State#TERMINATED terminated} or {@linkplain State#FAILED failed}.
         */
    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-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        service.stopAsync();
        service.stopAsync();
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
    
        executionThread.join();
      }
    
      public void testServiceExitingOnItsOwn() throws Exception {
    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)
Back to top