Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 336 for queue (0.17 sec)

  1. guava/src/com/google/common/cache/LocalCache.java

         * fraction of read operations.
         */
        final AtomicInteger readCount = new AtomicInteger();
    
        /**
         * A queue of elements currently in the map, ordered by write time. Elements are added to the
         * tail of the queue on write.
         */
        @GuardedBy("this")
        final Queue<ReferenceEntry<K, V>> writeQueue;
    
        /**
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 150.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/cache/CacheTesting.java

       * getting a bunch of different keys), then makes sure all the items in the cache are also in the
       * eviction queue. It will invoke the given {@code operation} on the first element in the eviction
       * queue, and then reverify that all items in the cache are in the eviction queue, and verify that
       * the head of the eviction queue has changed as a result of the operation.
       */
      static void checkRecency(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 16.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/EvictingQueue.java

    import java.util.Collection;
    import java.util.Queue;
    
    /**
     * A non-blocking queue which automatically evicts elements from the head of the queue when
     * attempting to add new elements onto the queue and it is full. This queue orders elements FIFO
     * (first-in-first-out). This data structure is logically equivalent to a circular buffer (i.e.,
     * cyclic buffer or ring buffer).
     *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Fri May 12 17:52:55 GMT 2023
    - 4.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt

        startNs = queue.taskRunner.backend.nanoTime()
        log(task, queue, "starting")
      }
    
      var completedNormally = false
      try {
        val result = block()
        completedNormally = true
        return result
      } finally {
        if (loggingEnabled) {
          val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs
          if (completedNormally) {
            log(task, queue, "finished run in ${formatDuration(elapsedNs)}")
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/ReferenceEntry.java

      /** Returns the next entry in the access queue. */
      ReferenceEntry<K, V> getNextInAccessQueue();
    
      /** Sets the next entry in the access queue. */
      void setNextInAccessQueue(ReferenceEntry<K, V> next);
    
      /** Returns the previous entry in the access queue. */
      ReferenceEntry<K, V> getPreviousInAccessQueue();
    
      /** Sets the previous entry in the access queue. */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Jun 15 18:00:07 GMT 2021
    - 3.5K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/collect/testing/TestQueueGenerator.java

    import java.util.Queue;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Creates queues, containing sample elements, to be tested.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public interface TestQueueGenerator<E extends @Nullable Object> extends TestCollectionGenerator<E> {
      @Override
      Queue<E> create(Object... elements);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 21 16:49:06 GMT 2024
    - 1.1K bytes
    - Viewed (0)
  7. guava/src/com/google/common/base/FinalizableWeakReference.java

      /**
       * Constructs a new finalizable weak reference.
       *
       * @param referent to weakly reference
       * @param queue that should finalize the referent
       */
      protected FinalizableWeakReference(@CheckForNull T referent, FinalizableReferenceQueue queue) {
        super(referent, queue.queue);
        queue.cleanUp();
      }
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 23 15:09:35 GMT 2023
    - 1.6K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/collect/testing/features/FeatureUtil.java

      @CanIgnoreReturnValue
      public static Set<Feature<?>> addImpliedFeatures(Set<Feature<?>> features) {
        Queue<Feature<?>> queue = new ArrayDeque<>(features);
        while (!queue.isEmpty()) {
          Feature<?> feature = queue.remove();
          for (Feature<?> implied : feature.getImpliedFeatures()) {
            if (features.add(implied)) {
              queue.add(implied);
            }
          }
        }
        return features;
      }
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 21 15:08:35 GMT 2022
    - 12.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/collect/EvictingQueueTest.java

        assertEquals(0, queue.size());
        assertEquals(3, queue.remainingCapacity());
    
        assertTrue(queue.add("one"));
        assertTrue(queue.add("two"));
        assertTrue(queue.add("three"));
        assertEquals("one", queue.element());
        assertEquals("one", queue.peek());
        assertEquals(3, queue.size());
        assertEquals(0, queue.remainingCapacity());
    
        assertTrue(queue.add("four"));
        assertEquals("two", queue.element());
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Feb 19 20:34:55 GMT 2024
    - 6.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/base/FinalizablePhantomReference.java

      /**
       * Constructs a new finalizable phantom reference.
       *
       * @param referent to phantom reference
       * @param queue that should finalize the referent
       */
      protected FinalizablePhantomReference(@CheckForNull T referent, FinalizableReferenceQueue queue) {
        super(referent, queue.queue);
        queue.cleanUp();
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 23 15:09:35 GMT 2023
    - 1.7K bytes
    - Viewed (0)
Back to top