- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for Striped (0.3 sec)
-
android/guava/src/com/google/common/util/concurrent/Striped.java
} /** * Creates a {@code Striped<Lock>} with eagerly initialized, strongly referenced locks. Every lock * is reentrant. * * @param stripes the minimum number of stripes (locks) required * @return a new {@code Striped<Lock>} */ public static Striped<Lock> lock(int stripes) { return custom(stripes, PaddedLock::new); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 10 20:55:18 GMT 2023 - 20.3K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
for (Striped<?> striped : allImplementations()) { assertBasicInvariants(striped); } } private static void assertBasicInvariants(Striped<?> striped) { Set<Object> observed = Sets.newIdentityHashSet(); // for the sake of weakly referenced locks. // this gets the stripes with #getAt(index) for (int i = 0; i < striped.size(); i++) { Object object = striped.getAt(i); assertNotNull(object);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
for (Striped<?> striped : allImplementations()) { assertBasicInvariants(striped); } } private static void assertBasicInvariants(Striped<?> striped) { Set<Object> observed = Sets.newIdentityHashSet(); // for the sake of weakly referenced locks. // this gets the stripes with #getAt(index) for (int i = 0; i < striped.size(); i++) { Object object = striped.getAt(i); assertNotNull(object);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.4K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java
EAGER { @Override Striped<Lock> get(int stripes) { return Striped.lock(stripes); } }, LAZY_SMALL { @Override Striped<Lock> get(int stripes) { return new Striped.SmallLazyStriped<>(stripes, LOCK_SUPPLIER); } }, LAZY_LARGE { @Override Striped<Lock> get(int stripes) { return new Striped.LargeLazyStriped<>(stripes, LOCK_SUPPLIER);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java
EAGER { @Override Striped<Lock> get(int stripes) { return Striped.lock(stripes); } }, LAZY_SMALL { @Override Striped<Lock> get(int stripes) { return new Striped.SmallLazyStriped<>(stripes, LOCK_SUPPLIER); } }, LAZY_LARGE { @Override Striped<Lock> get(int stripes) { return new Striped.LargeLazyStriped<>(stripes, LOCK_SUPPLIER);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
`Serpent, I say again!' repeated the Pigeon, but in a more subdued tone, and added with a kind of sob, `I've tried every way, and nothing seems to suit them!' `I haven't the least idea what you're talking about,' said Alice. `I've tried the roots of trees, and I've tried banks, and I've tried hedges,' the Pigeon went on, without attending to her; `but those serpents! There's no pleasing them!'
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) -
android/guava/src/com/google/common/io/BaseEncoding.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Mar 15 16:33:32 GMT 2024 - 41.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
// SequentialExecutor by the time the barrier is satisfied 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 {
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/ListenableFuture.java
* after executing them. * * @param listener the listener to run when the computation is complete * @param executor the executor to run the listener in * @throws RejectedExecutionException if we tried to execute the listener immediately but the * executor rejected it. */ void addListener(Runnable listener, Executor executor);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
guava/src/com/google/common/cache/Striped64.java
* the capacity, it is doubled in size unless some other thread * holds the lock. If a hashed slot is empty, and lock is * available, a new Cell is created. Otherwise, if the slot * exists, a CAS is tried. Retries proceed by "double hashing", * using a secondary hash (Marsaglia XorShift) to try to find a * free slot. * * The table size is capped because, when there are more threads
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.5K bytes - Viewed (0)