Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 209 for drained (0.07 sec)

  1. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.4K 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  4. src/bytes/buffer.go

    		c = 2 * cap(b)
    	}
    	b2 := append([]byte(nil), make([]byte, c)...)
    	i := copy(b2, b)
    	return b2[:i]
    }
    
    // WriteTo writes data to w until the buffer is drained or an error occurs.
    // The return value n is the number of bytes written; it always fits into an
    // int, but it is int64 to match the [io.WriterTo] interface. Any error
    // encountered during the write is also returned.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  5. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  6. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  7. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  8. 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 Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 12:18:32 UTC 2024
    - 315.4K bytes
    - Viewed (0)
  9. 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 Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 04:40:14 UTC 2024
    - 309.1K bytes
    - Viewed (0)
  10. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.6K bytes
    - Viewed (0)
Back to top