- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 212 for drained (0.05 sec)
-
guava-tests/test/com/google/common/collect/QueuesTest.java
assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, MILLISECONDS)); Producer producer = new Producer(q, 1); // producing one, will ask for two Future<?> producerThread = threadPool.submit(producer); producer.beganProducing.await(); // make sure we time out Stopwatch timer = Stopwatch.createStarted();
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Nov 04 17:24:58 UTC 2025 - 12.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
*/ long deadline = System.nanoTime() + unit.toNanos(timeout); int added = 0; while (added < numElements) { // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once) added += q.drainTo(buffer, numElements - added);Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Nov 04 17:24:58 UTC 2025 - 18.2K bytes - Viewed (0) -
guava/src/com/google/common/collect/Queues.java
*/ long deadline = System.nanoTime() + unit.toNanos(timeout); int added = 0; while (added < numElements) { // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once) added += q.drainTo(buffer, numElements - added);Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Nov 04 17:24:58 UTC 2025 - 18K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
* list's ordering. It is drained as a batch operation when either the DRAIN_THRESHOLD is * crossed or a write occurs on the segment. */ final Queue<ReferenceEntry<K, V>> recencyQueue; /** * A counter of the number of reads since the last write, used to drain queues on a small * fraction of read operations. */
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 19:35:11 UTC 2025 - 148.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
* * This implementation uses a per-segment queue to record a memento of the additions, removals, * and accesses that were performed on the map. The queue is drained on writes and when it exceeds * its capacity threshold. * * The Least Recently Used page replacement algorithm was chosen due to its simplicity, high hit
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 18:35:44 UTC 2025 - 89.9K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.31.md
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Wed Nov 12 11:33:21 UTC 2025 - 451.9K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.30.md
- Improved scheduler performance when no scoring plugins were defined. ([#122058](https://github.com/kubernetes/kubernetes/pull/122058), [@aleksandra-malinowska](https://github.com/aleksandra-malinowska)) - Improved scheduler performance when no scoring plugins were defined.
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Wed Jun 18 18:59:10 UTC 2025 - 398.1K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheStats.java
/** * Constructs a new {@code CacheStats} instance. * * <p>Five parameters of the same type in a row is a bad thing, but this class is not constructed * by end users and is too fine-grained for a builder. */ @SuppressWarnings("GoodTime") // should accept a java.time.Duration public CacheStats( long hitCount, long missCount, long loadSuccessCount, long loadExceptionCount,Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 12.6K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheStats.java
/** * Constructs a new {@code CacheStats} instance. * * <p>Five parameters of the same type in a row is a bad thing, but this class is not constructed * by end users and is too fine-grained for a builder. */ @SuppressWarnings("GoodTime") // should accept a java.time.Duration public CacheStats( long hitCount, long missCount, long loadSuccessCount, long loadExceptionCount,Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 12.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
} } /** * Performs a depth-first traversal of the graph edges defined by each node's {@code * allowedPriorLocks} to find a path between {@code this} and the specified {@code lock}. * * @return If a path was found, a chained {@link ExampleStackTrace} illustrating the path to the * {@code lock}, or {@code null} if no path was found. */Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 17:06:34 UTC 2025 - 35.9K bytes - Viewed (0)