- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for isTeminated (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)