Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 42 for ScheduledExecutorService (0.12 seconds)

  1. src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java

    import java.util.Comparator;
    import java.util.Enumeration;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.CIFSContext;
    import jcifs.Configuration;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 20K bytes
    - Click Count (0)
  2. docs/smb3-features/02-persistent-handles-design.md

        }
    }
    ```
    
    ### 4.5 Persistent Handle Manager
    ```java
    package jcifs.internal.smb2.persistent;
    
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.io.*;
    import java.nio.file.*;
    
    public class PersistentHandleManager {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 31.6K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.slf4j.Logger;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  4. docs/smb3-features/04-directory-leasing-design.md

            }
        }
    }
    ```
    
    ### 4.3 Directory Lease Manager
    ```java
    package jcifs.internal.smb2.lease;
    
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    
    public class DirectoryLeaseManager {
        private final CIFSContext context;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 36.2K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  6. src/main/java/jcifs/util/SmbCircuitBreaker.java

    import java.util.Deque;
    import java.util.List;
    import java.util.concurrent.ConcurrentLinkedDeque;
    import java.util.concurrent.CopyOnWriteArrayList;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  8. docs/smb3-features/03-multi-channel-design.md

        private final Map<String, ChannelInfo> channels;
        private final List<NetworkInterfaceInfo> localInterfaces;
        private final List<NetworkInterfaceInfo> remoteInterfaces;
        private final ScheduledExecutorService scheduler;
        private final ChannelLoadBalancer loadBalancer;
        private final ChannelFailover failover;
        
        private volatile boolean multiChannelEnabled;
        private final int maxChannels;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 39.6K bytes
    - Click Count (0)
  9. docs/recipes.md

                  (System.nanoTime() - startNanos) / 1e9f, e)
            }
          }
        ```
    === ":material-language-java: Java"
        ```java
          private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
          private final OkHttpClient client = new OkHttpClient();
    
          public void run() throws Exception {
            Request request = new Request.Builder()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 47.8K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.logging.LogRecord;
    import java.util.logging.Logger;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
Back to Top