Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for LinkedBlockingQueue (0.29 sec)

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

        Iterables.addAll(deque, elements);
        return deque;
      }
    
      // LinkedBlockingQueue
    
      /** 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<>();
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/Queues.java

        Iterables.addAll(deque, elements);
        return deque;
      }
    
      // LinkedBlockingQueue
    
      /** 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<>();
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/collect/testing/TestsForQueuesInJavaUtil.java

                new TestStringQueueGenerator() {
                  @Override
                  public Queue<String> create(String[] elements) {
                    return new LinkedBlockingQueue<>(MinimalCollection.of(elements));
                  }
                })
            .named("LinkedBlockingQueue")
            .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)
  4. guava-tests/test/com/google/common/collect/QueuesTest.java

       */
    
      public static List<BlockingQueue<Object>> blockingQueues() {
        return ImmutableList.<BlockingQueue<Object>>of(
            new LinkedBlockingQueue<Object>(),
            new LinkedBlockingQueue<Object>(10),
            new SynchronousQueue<Object>(),
            new ArrayBlockingQueue<Object>(10),
            new LinkedBlockingDeque<Object>(),
            new LinkedBlockingDeque<Object>(10),
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.regex.Matcher;
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 24.8K bytes
    - Viewed (0)
Back to top