- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 50 for awaitTermination (0.59 sec)
-
maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java
} } catch (Exception e) { session.getResult().addException(e); break; } } executor.shutdown(); executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS); } private void multiThreadedProjectTaskSegmentBuild( ConcurrencyDependencyGraph analyzer, ReactorContext reactorContext,
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Sep 22 09:07:17 GMT 2023 - 9.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java
while (!at.compareAndSet(2.0, 3.0)) { Thread.yield(); } } }); assertTrue(at.compareAndSet(1.0, 2.0)); awaitTermination(t); assertBitEquals(3.0, at.get()); } /** repeated weakCompareAndSet succeeds in changing value when equal to expected */ public void testWeakCompareAndSet() { double prev = Math.E;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 10.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheBuilderTest.java
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 25.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
threadPool = newCachedThreadPool(); } @Override public void tearDown() throws InterruptedException { threadPool.shutdown(); assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); } private static <T> int drain( BlockingQueue<T> q, Collection<? super T> buffer, int maxElements, long timeout, TimeUnit unit,
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
@Override @PreDestroy public void close() throws Exception { if (executorService != null) { try { executorService.shutdown(); executorService.awaitTermination(60, TimeUnit.SECONDS); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) { logger.debug("Interrupted.", e); } } finally {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 16.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
inputFuture.set("value"); future.cancel(false); // Unpause the executor. beforeFunction.countDown(); executor.shutdown(); assertTrue(executor.awaitTermination(5, SECONDS)); assertFalse(functionCalled.get()); } public void testSubmitAsync_asyncCallable_error() throws InterruptedException { final Error error = new Error("deliberate");
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
inputFuture.set("value"); future.cancel(false); // Unpause the executor. beforeFunction.countDown(); executor.shutdown(); assertTrue(executor.awaitTermination(5, SECONDS)); assertFalse(functionCalled.get()); } public void testSubmitAsync_asyncCallable_error() throws InterruptedException { final Error error = new Error("deliberate");
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
repeatedlyInterruptTestThread(20, tearDownStack); semaphore.tryAcquireUnsuccessfully(10, 70); assertInterrupted(); } // executor.awaitTermination Testcases public void testTryAwaitTerminationUninterruptiblyLongTimeUnit_success() { ExecutorService executor = newFixedThreadPool(1); requestInterruptIn(500); executor.execute(new SleepTask(1000));
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 30.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
repeatedlyInterruptTestThread(20, tearDownStack); semaphore.tryAcquireUnsuccessfully(10, 70); assertInterrupted(); } // executor.awaitTermination Testcases public void testTryAwaitTerminationUninterruptiblyDuration_success() { ExecutorService executor = newFixedThreadPool(1); requestInterruptIn(500); executor.execute(new SleepTask(1000));
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 31.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 23.2K bytes - Viewed (0)