Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 126 for terminated (0.05 sec)

  1. 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}.
         *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  2. 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}.
         */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  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}.
         *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  4. 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 {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractService.java

        return new ListenerCallQueue.Event<Listener>() {
          @Override
          public void call(Listener listener) {
            listener.terminated(from);
          }
    
          @Override
          public String toString() {
            return "terminated({from = " + from + "})";
          }
        };
      }
    
      private static ListenerCallQueue.Event<Listener> stoppingEvent(State from) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractService.java

        return new ListenerCallQueue.Event<Listener>() {
          @Override
          public void call(Listener listener) {
            listener.terminated(from);
          }
    
          @Override
          public String toString() {
            return "terminated({from = " + from + "})";
          }
        };
      }
    
      private static ListenerCallQueue.Event<Listener> stoppingEvent(State from) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

                this.finished = finished;
            }
    
            /**
             * Checks if the process has been terminated due to timeout.
             * @return True if the process was terminated, false otherwise.
             */
            public boolean isTeminated() {
                return teminated;
            }
        }
    
        /**
         * Thread that reads input stream data and buffers it for later retrieval.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        assertThrows(RejectedExecutionException.class, () -> executor.submit(doNothingRunnable));
        assertTrue(executor.isTerminated());
    
        otherThread.join(1000);
        assertEquals(Thread.State.TERMINATED, otherThread.getState());
        Throwable throwable = throwableFromOtherThread.get();
        assertNull(
            "Throwable from other thread: "
                + (throwable == null ? null : Throwables.getStackTraceAsString(throwable)),
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

                this.finished = finished;
            }
    
            /**
             * Returns whether the process was terminated.
             * @return true if terminated, false otherwise.
             */
            public boolean isTeminated() {
                return teminated;
            }
        }
    
        /**
         * Thread to read and buffer output from an input stream.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 16K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/job/PythonJobTest.java

            assertTrue(result.contains("Python Process terminated."));
        }
    
        // Test execute with timeout
        public void test_execute_withTimeout() {
            pythonJob.filename("timeout.py");
            pythonJob.timeout = 60; // Set timeout
            pythonJob.processTimeout = true;
    
            testProcessHelper.exitValue = -1;
            testProcessHelper.processOutput = "Process terminated";
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 22.1K bytes
    - Viewed (0)
Back to top