- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 118 for drained (0.05 sec)
-
android/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 Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 12.2K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 18.3K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 18.1K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 90K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.31.md
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Wed Aug 13 19:49:57 UTC 2025 - 429.6K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 12.6K 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 Sep 05 09:05:11 UTC 2025 - Last Modified: Wed Jun 18 18:59:10 UTC 2025 - 398.1K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/exception/JobProcessingExceptionTest.java
assertEquals(message, exception.getMessage()); assertNull(exception.getCause()); } public void test_constructor_withCauseChain() { // Test constructor with chained exceptions final Exception rootCause = new IllegalArgumentException("Invalid argument"); final Exception middleCause = new RuntimeException("Runtime error", rootCause);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 7K bytes - Viewed (0) -
android/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 Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 18 15:05:43 UTC 2025 - 35.9K bytes - Viewed (0) -
guava/src/com/google/common/net/MediaType.java
public static final MediaType WEBM_AUDIO = createConstant(AUDIO_TYPE, "webm"); /** * L16 audio, as defined by <a href="https://tools.ietf.org/html/rfc2586">RFC 2586</a>. * * @since 24.1 */ public static final MediaType L16_AUDIO = createConstant(AUDIO_TYPE, "l16"); /** * L24 audio, as defined by <a href="https://tools.ietf.org/html/rfc3190">RFC 3190</a>. * * @since 20.0 */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 48K bytes - Viewed (0)