Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for newLinkedBlockingQueue (0.1 seconds)

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

      /** Creates an empty {@code LinkedBlockingQueue} with a capacity of {@link Integer#MAX_VALUE}. */
      @J2ktIncompatible
      @GwtIncompatible // LinkedBlockingQueue
      public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() {
        return new LinkedBlockingQueue<>();
      }
    
      /**
       * Creates an empty {@code LinkedBlockingQueue} with the given (fixed) capacity.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 18.2K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/Queues.java

      /** Creates an empty {@code LinkedBlockingQueue} with a capacity of {@link Integer#MAX_VALUE}. */
      @J2ktIncompatible
      @GwtIncompatible // LinkedBlockingQueue
      public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() {
        return new LinkedBlockingQueue<>();
      }
    
      /**
       * Creates an empty {@code LinkedBlockingQueue} with the given (fixed) capacity.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 18K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

        checkNotNull(unit);
        int ntasks = tasks.size();
        checkArgument(ntasks > 0);
        List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks);
        BlockingQueue<Future<T>> futureQueue = Queues.newLinkedBlockingQueue();
        long timeoutNanos = unit.toNanos(timeout);
    
        // For efficiency, especially in executors with limited
        // parallelism, check to see if previously submitted tasks are
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 45.6K bytes
    - Click Count (0)
Back to Top