Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for LinkedBlockingQueue (0.1 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. okhttp/src/test/java/okhttp3/DuplexTest.kt

    import java.net.HttpURLConnection
    import java.net.ProtocolException
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.Executors
    import java.util.concurrent.LinkedBlockingQueue
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.internal.duplex.MockStreamHandler
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K 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. okhttp/src/test/java/okhttp3/InterceptorTest.kt

    import assertk.assertions.isTrue
    import java.io.IOException
    import java.net.SocketTimeoutException
    import java.time.Duration
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.LinkedBlockingQueue
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.ThreadPoolExecutor
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicReference
    import kotlin.test.assertFailsWith
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

    import java.util.HashSet;
    import java.util.LinkedList;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

    import java.security.cert.X509Certificate
    import java.util.Collections
    import java.util.Locale
    import java.util.concurrent.ConcurrentHashMap
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.LinkedBlockingQueue
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicInteger
    import java.util.logging.Level
    import java.util.logging.Logger
    import javax.net.ServerSocketFactory
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
Back to top