Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 19 for STOPPING (0.04 seconds)

  1. 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) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 2.1K bytes
    - Click Count (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) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 2.1K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

          if (state != null) {
            state.transitionService(service, STARTING, RUNNING);
          }
        }
    
        @Override
        public void stopping(State from) {
          ServiceManagerState state = this.state.get();
          if (state != null) {
            state.transitionService(service, from, STOPPING);
          }
        }
    
        @Override
        public void terminated(State from) {
          ServiceManagerState state = this.state.get();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 33.2K bytes
    - Click Count (1)
  4. 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();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 12.8K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/TestThread.java

       *
       * Our usages should at least be *relatively* safe: Typically, threads started by a test are dying
       * at the end of the test, so there is no object state put at risk by stopping the threads
       * abruptly. In other cases, a test may put a thread into an uninterruptible operation
       * intentionally, so there is no other way to clean up these threads. (The better solution,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  6. 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();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 12.8K bytes
    - Click Count (0)
  7. 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();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 28.7K bytes
    - Click Count (0)
  8. 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();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 28.7K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

       *
       * Our usages should at least be *relatively* safe: Typically, threads started by a test are dying
       * at the end of the test, so there is no object state put at risk by stopping the threads
       * abruptly. In other cases, a test may put a thread into an uninterruptible operation
       * intentionally, so there is no other way to clean up these threads. (The better solution,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

         */
        @PreDestroy
        public void destroy() {
            for (final String sessionId : runningProcessMap.keySet()) {
                if (logger.isInfoEnabled()) {
                    logger.info("Stopping process {}", sessionId);
                }
                if (destroyProcess(sessionId) == 0 && logger.isInfoEnabled()) {
                    logger.info("Stopped process {}", sessionId);
                }
            }
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 06:54:47 GMT 2025
    - 10.9K bytes
    - Click Count (0)
Back to Top