Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 29 of 29 for blockingQueues (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  2. github.com/codelibs/jcifs

    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;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  3. github.com/codelibs/jcifs

    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;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 35.9K bytes
    - Click Count (0)
  4. github.com/google/guava

    android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java 

    import java.util.Iterator;
import java.util.NoSuchElementException;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
import org.jspecify.annotations.NullUnmarked;
import org.jspecify.annotations.Nullable;

/**
 * A bounded {@linkplain BlockingQueue blocking queue} backed by an array. This queue orders
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 22.4K bytes
    - Click Count (0)
  5. github.com/google/guava

    android/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;
    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)
  6. github.com/square/okhttp

    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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 25.8K bytes
    - Click Count (0)
  7. github.com/codelibs/fess

    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;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jan 01 12:47:47 GMT 2026
    - 27.2K bytes
    - Click Count (0)
  8. github.com/square/okhttp

    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 {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  9. github.com/square/okhttp

    okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt 

    import assertk.fail
import java.io.IOException
import java.net.HttpURLConnection
import java.net.SocketTimeoutException
import java.time.Duration
import java.util.Arrays
import java.util.concurrent.BlockingQueue
import java.util.concurrent.CountDownLatch
import java.util.concurrent.Executors
import java.util.concurrent.LinkedBlockingQueue
import java.util.concurrent.SynchronousQueue
import java.util.concurrent.TimeUnit
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 67.5K bytes
    - Click Count (0)
  10. github.com/square/okhttp

    okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt 

    import java.net.Proxy
import java.net.SocketTimeoutException
import java.net.UnknownHostException
import java.net.UnknownServiceException
import java.time.Duration
import java.util.Arrays
import java.util.concurrent.BlockingQueue
import java.util.concurrent.CountDownLatch
import java.util.concurrent.Executors
import java.util.concurrent.SynchronousQueue
import java.util.concurrent.TimeUnit
import java.util.concurrent.atomic.AtomicBoolean
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
Back to Top