- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for Hockin (1.28 sec)
-
android/guava/src/com/google/common/cache/CacheBuilder.java
* uncommon to specify {@code concurrencyLevel(1)} in order to achieve more deterministic eviction * behavior. * * <p>Note that future implementations may abandon segment locking in favor of more advanced * concurrency controls. * * @return this {@code CacheBuilder} instance (for chaining) * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 44.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
/* * TODO(cpovirk): move ForwardingTestCase somewhere common, and use it to * test the forwarded methods */ } @AndroidIncompatible // Mocking ExecutorService is forbidden there. TODO(b/218700094): Don't mock. public void testListeningDecorator_noWrapExecuteTask() { ExecutorService delegate = mock(ExecutorService.class);
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/src/com/google/common/base/Suppliers.java
MemoizingSupplier(Supplier<T> delegate) { this.delegate = checkNotNull(delegate); } @Override @ParametricNullness public T get() { // A 2-field variant of Double Checked Locking. if (!initialized) { synchronized (this) { if (!initialized) { T t = delegate.get(); value = t; initialized = true; return t;
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 15.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
boolean lockAcquired = tryLockUninterruptibly(lock, 500, MILLISECONDS); assertFalse(lockAcquired); assertAtLeastTimePassed(stopwatch, 500); assertNotInterrupted(); // finish locking thread lockThread.interrupt(); } public void testTryLockTimeoutNotExceeded() { Stopwatch stopwatch = Stopwatch.createStarted(); Lock lock = new ReentrantLock();
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/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
} /** * Saves the state to a stream (that is, serializes it). This merely wraps default serialization * within the monitor. The serialization strategy for items is left to underlying Queue. Note that * locking is not needed on deserialization, so readObject is not defined, just relying on * default. */ private void writeObject(java.io.ObjectOutputStream s) throws java.io.IOException { monitor.enter(); try {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 19.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Striped.java
* for (Lock lock : locks) { * lock.unlock(); * } * * If we only held the int[] stripes, translating it on the fly to L's, the original locks might * be garbage collected after locking them, ending up in a huge mess. */ @SuppressWarnings("unchecked") // we carefully replaced all keys with their respective L's List<L> asStripes = (List<L>) result;
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) -
android/guava/src/com/google/common/collect/Ordering.java
return "Ordering.arbitrary()"; } /* * We need to be able to mock identityHashCode() calls for tests, because it * can take 1-10 seconds to find colliding objects. Mocking frameworks that * can do magic to mock static method calls still can't do so for a system * class, so we need the indirection. In production, Hotspot should still
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 24 19:38:27 GMT 2024 - 39.4K bytes - Viewed (0)