- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for BlockingQueue (1.43 sec)
-
src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java
*/ package jcifs.internal.smb2.rdma; import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.atomic.AtomicInteger; /** * Abstract base class for RDMA connections. *
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 8.2K 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) -
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) -
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)