Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 118 for drained (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. CHANGELOG/CHANGELOG-1.31.md

    - Supported fine-grained supplemental groups policy (KEP-3619), which enabled
      fine-grained control for supplementary groups in the first container processes.
      This allows you to choose whether to include groups defined in the container image (/etc/groups)
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 13 19:49:57 UTC 2025
    - 429.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top