Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for semaphore (0.07 seconds)

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

  1. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      public static boolean tryAcquireUninterruptibly(Semaphore semaphore, Duration timeout) {
        return tryAcquireUninterruptibly(semaphore, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
       * Invokes {@code semaphore.}{@link Semaphore#tryAcquire(int, long, TimeUnit) tryAcquire(1,
       * timeout, unit)} uninterruptibly.
       *
       * @since 18.0
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 19.8K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            @Override
            public Lock get() {
              return new ReentrantLock(true);
            }
          };
    
      private static final Supplier<Semaphore> SEMAPHORE_SUPPLER =
          new Supplier<Semaphore>() {
            @Override
            public Semaphore get() {
              return new Semaphore(1, false);
            }
          };
    
      private static List<Striped<?>> weakImplementations() {
        return ImmutableList.<Striped<?>>builder()
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            @Override
            public Lock get() {
              return new ReentrantLock(true);
            }
          };
    
      private static final Supplier<Semaphore> SEMAPHORE_SUPPLER =
          new Supplier<Semaphore>() {
            @Override
            public Semaphore get() {
              return new Semaphore(1, false);
            }
          };
    
      private static List<Striped<?>> weakImplementations() {
        return ImmutableList.<Striped<?>>builder()
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  4. src/main/java/jcifs/util/SmbCircuitBreaker.java

    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;
    import java.util.concurrent.atomic.AtomicLong;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.function.Supplier;
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb/SmbTransportImpl.java

        private final CIFSContext transportContext;
        private final boolean signingEnforced;
    
        private SmbNegotiationResponse negotiated;
    
        private SMBSigningDigest digest;
    
        private final Semaphore credits = new Semaphore(1, true);
    
        private final int desiredCredits = 512;
    
        private byte[] preauthIntegrityHash = new byte[64];
        private final Object preauthHashLock = new Object();
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 69.8K bytes
    - Click Count (0)
  6. src/cmd/api/main_test.go

    	importMap   map[string]map[string]string // import path → canonical import path
    }
    
    var listCache sync.Map // map[string]listImports, keyed by contextName
    
    // listSem is a semaphore restricting concurrent invocations of 'go list'. 'go
    // list' has its own internal concurrency, so we use a hard-coded constant (to
    // allow the I/O-intensive phases of 'go list' to overlap) instead of scaling
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Feb 20 03:25:33 GMT 2025
    - 31.4K bytes
    - Click Count (0)
Back to Top