Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for isTeminated (0.07 sec)

  1. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

                }
                if (exitValue == 143 && mt.isTeminated()) {
                    throw new CommandExecutionException("The command execution is timeout: " + String.join(" ", commands));
                }
                return exitValue;
            } catch (final CrawlerSystemException e) {
                throw e;
            } catch (final InterruptedException e) {
                if (mt != null && mt.isTeminated()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

                      assertTrue(executor.isTerminated());
                    } catch (Throwable t) {
                      throwableFromOtherThread.set(t);
                    }
                  }
                });
    
        otherThread.start();
    
        // WAIT #1
        barrier.await(1, SECONDS);
        assertFalse(executor.isShutdown());
        assertFalse(executor.isTerminated());
    
        executor.shutdown();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        TestExecutor testExecutor = new TestExecutor(mock);
        assertFalse(testExecutor.awaitTermination(10, MILLISECONDS));
        mock.assertLastMethodCalled("awaitTermination");
        assertFalse(testExecutor.isTerminated());
        mock.assertLastMethodCalled("isTerminated");
        assertFalse(testExecutor.isShutdown());
        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  4. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
        assertFalse(executor.isShutdown());
        assertFalse(executor.isTerminated());
        executor.shutdown();
        assertTrue(executor.isShutdown());
        assertTrue(executor.isTerminated());
      }
    
      public void testNoOpScheduledExecutorInvokeAll() throws ExecutionException, InterruptedException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  5. guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
        assertFalse(executor.isShutdown());
        assertFalse(executor.isTerminated());
        executor.shutdown();
        assertTrue(executor.isShutdown());
        assertTrue(executor.isTerminated());
      }
    
      public void testNoOpScheduledExecutorInvokeAll() throws ExecutionException, InterruptedException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

        return delegate().invokeAny(tasks, timeout, unit);
      }
    
      @Override
      public boolean isShutdown() {
        return delegate().isShutdown();
      }
    
      @Override
      public boolean isTerminated() {
        return delegate().isTerminated();
      }
    
      @Override
      public void shutdown() {
        delegate().shutdown();
      }
    
      @Override
      @CanIgnoreReturnValue
      public List<Runnable> shutdownNow() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java

        return delegate.shutdownNow();
      }
    
      @Override
      public final boolean isShutdown() {
        return delegate.isShutdown();
      }
    
      @Override
      public final boolean isTerminated() {
        return delegate.isTerminated();
      }
    
      @Override
      public final boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        return delegate.awaitTermination(timeout, unit);
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        return delegate.shutdownNow();
      }
    
      @Override
      public boolean isShutdown() {
        return delegate.isShutdown();
      }
    
      @Override
      public boolean isTerminated() {
        return delegate.isTerminated();
      }
    
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        Preconditions.checkNotNull(unit, "unit must not be null!");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        return delegate.shutdownNow();
      }
    
      @Override
      public boolean isShutdown() {
        return delegate.isShutdown();
      }
    
      @Override
      public boolean isTerminated() {
        return delegate.isTerminated();
      }
    
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        Preconditions.checkNotNull(unit, "unit must not be null!");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        assertFalse(executor.isTerminated());
        assertInterrupted();
      }
    
      public void testTryAwaitTerminationInfiniteTimeout() {
        ExecutorService executor = newFixedThreadPool(1);
        requestInterruptIn(500);
        executor.execute(new SleepTask(1000));
        executor.shutdown();
        awaitTerminationUninterruptibly(executor);
        assertTrue(executor.isTerminated());
        assertInterrupted();
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 31.7K bytes
    - Viewed (0)
Back to top