- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 32 for blockingQueues (0.05 sec)
-
android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
import java.util.Random; import java.util.Set; import java.util.SortedMap; import java.util.SortedSet; import java.util.UUID; import java.util.concurrent.BlockingDeque; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ConcurrentNavigableMap; import java.util.concurrent.ConcurrentSkipListMap;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 20.9K bytes - Viewed (0) -
src/main/java/jcifs/audit/SecurityAuditLogger.java
*/ package jcifs.audit; import java.time.Instant; import java.time.format.DateTimeFormatter; import java.util.HashMap; import java.util.Map; import java.util.Queue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 26.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt
import assertk.assertions.isSameInstanceAs 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
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 16:11:23 UTC 2025 - 28.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
import java.lang.Thread.State; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.CyclicBarrier; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 12 00:25:21 UTC 2025 - 26.5K bytes - Viewed (0) -
docs/smb3-features/05-rdma-smb-direct-design.md
REMOTE_WRITE, MEMORY_BIND } ``` ## 4. Data Structures ### 4.1 RDMA Connection ```java package jcifs.internal.smb2.rdma; import java.nio.ByteBuffer; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.atomic.AtomicInteger; public abstract class RdmaConnection implements AutoCloseable { protected final InetSocketAddress remoteAddress;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 35.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
import java.lang.reflect.InvocationTargetException; import java.time.Duration; import java.util.Collection; import java.util.Iterator; import java.util.List; import java.util.concurrent.BlockingQueue; import java.util.concurrent.Callable; import java.util.concurrent.Delayed; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 08 18:55:33 UTC 2025 - 45.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
import assertk.assertions.isNull import assertk.assertions.isTrue import assertk.assertions.prop import java.io.IOException 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
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 25.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java
import java.nio.file.Path; import java.nio.file.attribute.BasicFileAttributes; 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;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 27K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
import java.security.ProtectionDomain; import java.security.SecurityPermission; import java.util.Date; import java.util.NoSuchElementException; import java.util.PropertyPermission; import java.util.concurrent.BlockingQueue; import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.CyclicBarrier; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:07:52 UTC 2025 - 37.8K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public fun close ()V public fun dispatch (Lmockwebserver3/RecordedRequest;)Lmockwebserver3/MockResponse; public fun enqueue (Lmockwebserver3/MockResponse;)V protected final fun getResponseQueue ()Ljava/util/concurrent/BlockingQueue; public fun peek ()Lmockwebserver3/MockResponse; public fun setFailFast (Lmockwebserver3/MockResponse;)V public fun setFailFast (Z)V } public final class mockwebserver3/RecordedRequest {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 11.8K bytes - Viewed (0)