- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for semaphore (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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)