- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for Married (0.18 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
barrier.await(1, TimeUnit.SECONDS); // WAIT #2 barrier.await(1, TimeUnit.SECONDS); assertTrue(executor.isShutdown()); assertFalse(executor.isTerminated()); // WAIT #3 barrier.await(1, TimeUnit.SECONDS);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureInnocuousThreadTest.java
// Setting a security manager causes the common ForkJoinPool to use InnocuousThreads with no // permissions. // submit()/join() causes this thread to execute the task instead, so we use a CountDownLatch as // a barrier to synchronize. // TODO(cpovirk): If some other test already initialized commonPool(), this won't work :( // Maybe we should just run this test in its own VM. ForkJoinPool.commonPool() .execute(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 2020 - 5.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/graph/ValueGraphTest.java
graph.putEdgeValue(3, 4, "B"); graph.putEdgeValue(5, 6, "C"); int threadCount = 20; ExecutorService executor = newFixedThreadPool(threadCount); final CyclicBarrier barrier = new CyclicBarrier(threadCount); ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); for (int i = 0; i < threadCount; i++) { futures.add( executor.submit(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 17.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} }); final CyclicBarrier barrier = new CyclicBarrier(numThreads + 1); Runnable wrapper = new Runnable() { @Override public void run() { awaitUnchecked(barrier); task.run(); awaitUnchecked(barrier); } }; for (int j = 0; j < 10; j++) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
was heard in the distance. `Come on!' cried the Gryphon, and, taking Alice by the hand, it hurried off, without waiting for the end of the song. `What trial is it?' Alice panted as she ran; but the Gryphon only answered `Come on!' and ran the faster, while more and more faintly came, carried on the breeze that followed them, the melancholy words:-- `Soo--oop of the e--e--evening,
Plain Text - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 29 21:35:03 GMT 2012 - 145.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/graph/ValueGraphTest.java
graph.putEdgeValue(3, 4, "B"); graph.putEdgeValue(5, 6, "C"); int threadCount = 20; ExecutorService executor = newFixedThreadPool(threadCount); final CyclicBarrier barrier = new CyclicBarrier(threadCount); ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); for (int i = 0; i < threadCount; i++) { futures.add( executor.submit(
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 06 18:35:19 GMT 2024 - 20K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} final CyclicBarrier barrier = new CyclicBarrier( 6 // for the setter threads + 50 // for the listeners + 50 // for the blocking get threads, + 1); // for the main thread final ExecutorService executor = Executors.newFixedThreadPool(barrier.getParties());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
barrier.await(1, TimeUnit.SECONDS); executor.execute(barrierTask); // timeout means the second task wasn't even tried barrier.await(1, TimeUnit.SECONDS); } finally { service.shutdown(); } } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception { final CountDownLatch latch = new CountDownLatch(1);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* * It is important to realize that such a RateLimiter has a very superficial memory of the past: * it only remembers the last request. What if the RateLimiter was unused for a long period of * time, then a request arrived and was immediately granted? This RateLimiter would immediately * forget about that past underutilization. This may result in either underutilization or
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 19.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} }); final CyclicBarrier barrier = new CyclicBarrier(numThreads + 1); Runnable wrapper = new Runnable() { @Override public void run() { awaitUnchecked(barrier); task.run(); awaitUnchecked(barrier); } }; for (int j = 0; j < 10; j++) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0)