Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 42 for ScheduledExecutorService (0.14 seconds)

  1. docs/smb3-features/06-witness-protocol-design.md

        private final CIFSContext context;
        private final ConcurrentHashMap<String, WitnessRegistration> registrations;
        private final ConcurrentHashMap<String, WitnessNotificationListener> listeners;
        private final ScheduledExecutorService scheduler;
        private final WitnessRpcClient rpcClient;
        
        // Witness service endpoint
        private static final String WITNESS_SERVICE_UUID = "ccd8c074-d0e5-4a40-92b4-d074faa6ba28";
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 42K bytes
    - Click Count (0)
  2. src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseManager.java

    import java.io.IOException;
    import java.util.ArrayList;
    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 org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.CIFSContext;
    import jcifs.Configuration;
    import jcifs.smb.SmbFile;
    
    /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 01:47:47 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  3. src/main/java/jcifs/util/AuthenticationRateLimiter.java

    package jcifs.util;
    
    import java.time.Duration;
    import java.time.Instant;
    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.AtomicBoolean;
    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: Sat Aug 30 05:58:03 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/Futures.java

       */
      @J2ktIncompatible
      @GwtIncompatible // java.util.concurrent.ScheduledExecutorService
      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      // TODO(cpovirk): Return ListenableScheduledFuture?
      public static <O extends @Nullable Object> ListenableFuture<O> scheduleAsync(
          AsyncCallable<O> callable, Duration delay, ScheduledExecutorService executorService) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  5. src/main/java/jcifs/util/ResourceManager.java

    import java.util.Collections;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.slf4j.Logger;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/witness/WitnessClient.java

    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.CompletableFuture;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.CIFSContext;
    import jcifs.internal.witness.WitnessRegistration.WitnessRegistrationState;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 20.8K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb/MultiChannelManager.java

    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.CopyOnWriteArrayList;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.FutureTask;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ScheduledThreadPoolExecutor;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.ThreadPoolExecutor;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  9. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

    import java.lang.ref.WeakReference;
    import java.util.Map;
    import java.util.concurrent.CompletableFuture;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 18.8K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.FutureTask;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ScheduledThreadPoolExecutor;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.ThreadPoolExecutor;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
Back to Top