Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for LinkedBlockingQueue (0.09 sec)

  1. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/thumbnail/ThumbnailManagerTest.java

    import java.io.File;
    import java.io.IOException;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.LinkedBlockingQueue;
    
    import org.codelibs.core.misc.Tuple3;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.exception.FessSystemException;
    import org.codelibs.fess.helper.SystemHelper;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  3. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  4. android/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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 28.2K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

    import java.util.LinkedList;
    import java.util.List;
    import java.util.Map;
    import java.util.Objects;
    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.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

    import java.security.cert.CertificateException
    import java.security.cert.X509Certificate
    import java.util.Collections
    import java.util.Locale
    import java.util.concurrent.ConcurrentHashMap
    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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/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.junit5.StartStop
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  9. 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 Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 26.9K bytes
    - Viewed (0)
Back to top