- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 82 for mock (0.15 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
* as well as to handle state changes in a thread-safe manner. The current state of the future * is held in the Sync state, and the lock is released whenever the state changes to {@link * #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED} * * <p>To avoid races between threads doing release and acquire, we transition to the final state
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheTesting.java
for (Segment<?, ?> segment : map.segments) { drainRecencyQueue(segment); } } } static void drainRecencyQueue(Segment<?, ?> segment) { segment.lock(); try { segment.cleanUp(); } finally { segment.unlock(); } } static void drainReferenceQueues(Cache<?, ?> cache) { if (hasLocalCache(cache)) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 16.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/PeekingIterator.java
* * <p>See the Guava User Guide article on <a href= * "https://github.com/google/guava/wiki/CollectionHelpersExplained#peekingiterator">{@code * PeekingIterator}</a>. * * @author Mick Killianey * @since 2.0 */ @DoNotMock("Use Iterators.peekingIterator") @GwtCompatible @ElementTypesAreNonnullByDefault public interface PeekingIterator<E extends @Nullable Object> extends Iterator<E> { /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Jan 24 17:47:51 GMT 2022 - 2.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
} @Override public E element() { assertTrue(Thread.holdsLock(mutex)); return delegate.element(); } @Override public Iterator<E> iterator() { // We explicitly don't lock for iterator() assertFalse(Thread.holdsLock(mutex)); return delegate.iterator(); } @Override public int size() { assertTrue(Thread.holdsLock(mutex)); return delegate.size();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 7.4K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/BloomFilterStrategies.java
return Longs.fromBytes( bytes[15], bytes[14], bytes[13], bytes[12], bytes[11], bytes[10], bytes[9], bytes[8]); } }; /** * Models a lock-free array of bits. * * <p>We use this instead of java.util.BitSet because we need access to the array of longs and we * need compare-and-swap. */ static final class LockFreeBitArray {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 10.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* * <ol> * <li>Update the {@link #servicesByState()} * <li>Update the {@link #startupTimers} * <li>Based on the new state queue listeners to run * <li>Run the listeners (outside of the lock) * </ol> */ void transitionService(final Service service, State from, State to) { checkNotNull(service); checkArgument(from != to); monitor.enter(); try {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/BloomFilter.java
* generated today may <i>not</i> be readable by a binary that was compiled 6 months ago). * * <p>As of Guava 23.0, this class is thread-safe and lock-free. It internally uses atomics and * compare-and-swap to ensure correctness when multiple threads are used to access it. * * @param <T> the type of instances that the {@code BloomFilter} accepts * @author Dimitris Andreou
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 23.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 16.1K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
* </ul> * * The last point is subtle. Often the observable object will be managing its own internal state * using a lock, however it is dangerous to dispatch listeners while holding a lock because they * might run on the {@code directExecutor()} or be otherwise re-entrant (call back into your * object). So it is important to not call {@link #dispatch} while holding any locks. This is why
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
} @Override public E element() { assertTrue(Thread.holdsLock(mutex)); return delegate.element(); } @Override public Iterator<E> iterator() { // We explicitly don't lock for iterator() assertFalse(Thread.holdsLock(mutex)); return delegate.iterator(); } @Override public int size() { assertTrue(Thread.holdsLock(mutex)); return delegate.size();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 7.4K bytes - Viewed (0)