Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ConcurrentLinkedQueue (0.23 sec)

  1. guava/src/com/google/common/collect/Queues.java

        return deque;
      }
    
      // ConcurrentLinkedQueue
    
      /** Creates an empty {@code ConcurrentLinkedQueue}. */
      @J2ktIncompatible
      @GwtIncompatible // ConcurrentLinkedQueue
      public static <E> ConcurrentLinkedQueue<E> newConcurrentLinkedQueue() {
        return new ConcurrentLinkedQueue<>();
      }
    
      /**
       * Creates a {@code ConcurrentLinkedQueue} containing the elements of the specified iterable, in
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

            }
            return queueHolder;
        }
    
        protected static class QueueHolder {
            protected Queue<OpenSearchUrlQueue> waitingQueue = new ConcurrentLinkedQueue<>();
    
            protected Queue<OpenSearchUrlQueue> crawlingQueue = new ConcurrentLinkedQueue<>();
        }
    
        public void setPollingFetchSize(final int pollingFetchSize) {
            this.pollingFetchSize = pollingFetchSize;
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Queues.java

        return deque;
      }
    
      // ConcurrentLinkedQueue
    
      /** Creates an empty {@code ConcurrentLinkedQueue}. */
      @J2ktIncompatible
      @GwtIncompatible // ConcurrentLinkedQueue
      public static <E> ConcurrentLinkedQueue<E> newConcurrentLinkedQueue() {
        return new ConcurrentLinkedQueue<>();
      }
    
      /**
       * Creates a {@code ConcurrentLinkedQueue} containing the elements of the specified iterable, in
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/collect/testing/TestsForQueuesInJavaUtil.java

                new TestStringQueueGenerator() {
                  @Override
                  public Queue<String> create(String[] elements) {
                    return new ConcurrentLinkedQueue<>(MinimalCollection.of(elements));
                  }
                })
            .named("ConcurrentLinkedQueue")
            .withFeatures(
                CollectionFeature.GENERAL_PURPOSE, CollectionFeature.KNOWN_ORDER, CollectionSize.ANY)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/collect/testing/Helpers.java

       *     the size method
       */
      public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) {
        // It would be nice to be able to return a real concurrent
        // collection like ConcurrentLinkedQueue, so that e.g. concurrent
        // iteration would work, but that would not be GWT-compatible.
        // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt.
        return new AbstractList<T>() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/collect/testing/Helpers.java

       *     the size method
       */
      public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) {
        // It would be nice to be able to return a real concurrent
        // collection like ConcurrentLinkedQueue, so that e.g. concurrent
        // iteration would work, but that would not be GWT-compatible.
        // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt.
        return new AbstractList<T>() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 17.5K bytes
    - Viewed (0)
Back to top