- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for Barbier (0.13 sec)
-
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++) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 7.3K 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());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K 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);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.4K bytes - Viewed (0) -
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);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 28.2K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableSortedMap.java
* IllegalArgumentException} if passed a {@code fromKey} less than an earlier {@code fromKey}. * However, this method doesn't throw an exception in that situation, but instead keeps the * original {@code fromKey}. Similarly, this method keeps the original {@code toKey}, instead of * throwing an exception, if passed a {@code toKey} greater than an earlier {@code toKey}. */ @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 50.3K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/EndpointPair.java
// Why? The second half of condition2 requires that nodeV equals other.nodeU. // We already know that nodeU equals other.nodeU. Combined with the earlier statement, // and the transitive property of equality, this implies that nodeU equals nodeV. // If nodeU equals nodeV, condition1 == condition2, so checking condition1 is sufficient.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Oct 01 17:18:04 UTC 2021 - 8.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/features/FeatureUtil.java
if (!Collections.disjoint(newFeatures, earlierFeatures)) { throw new ConflictingRequirementsException( String.format( Locale.ROOT, "Annotation requires to be %s features that earlier " + "annotations required to be %s.", newRequirement, earlierRequirement), intersection(newFeatures, earlierFeatures), source); } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 21 15:08:35 UTC 2022 - 12.1K bytes - Viewed (0) -
android/guava/src/com/google/common/base/FinalizableReferenceQueue.java
* {@link FinalizableReference#finalizeReferent()} on them. * * <p>Keep a strong reference to this object until all of the associated referents have been * finalized. If this object is garbage collected earlier, the backing thread will not invoke {@code * finalizeReferent()} on the remaining references. * * <p>As an example of how this is used, imagine you have a class {@code MyServer} that creates a
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 26 20:07:17 UTC 2023 - 13.1K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Murmur3_32HashFunction.java
return hashBytes(input.toString().getBytes(charset)); } i++; buffer |= codePointToFourUtf8Bytes(codePoint) << shift; if (supplementaryPlaneFix) { // bug compatibility: earlier versions did not have this add shift += 32; } len += 4; } if (shift >= 32) { int k1 = mixK1((int) buffer); h1 = mixH1(h1, k1);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jun 15 20:59:00 UTC 2022 - 11.9K bytes - Viewed (0) -
guava/src/com/google/common/base/Suppliers.java
* * <p>When the underlying delegate throws an exception then this memoizing supplier will keep * delegating calls until it returns valid data. * * <p>If {@code delegate} is an instance created by an earlier call to {@code memoize}, it is * returned directly. */ public static <T extends @Nullable Object> Supplier<T> memoize(Supplier<T> delegate) { if (delegate instanceof NonSerializableMemoizingSupplier
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 15.3K bytes - Viewed (0)