- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 765 for Lock (0.02 sec)
-
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* * Lock lockA = factory1.newReentrantLock(MyLockOrder.FIRST); * Lock lockB = factory1.newReentrantLock(MyLockOrder.FIRST); * Lock lockC = factory2.newReentrantLock(MyLockOrder.FIRST); * * lockA.lock(); * * lockB.lock(); // will throw an IllegalStateException * lockC.lock(); // will throw an IllegalStateException * * lockA.lock(); // reentrant acquisition is okay * }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 18 15:05:43 UTC 2025 - 35.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
} ReentrantLock lock = this.lock; lock.lock(); boolean satisfied = false; try { return satisfied = guard.isSatisfied(); } finally { if (!satisfied) { lock.unlock(); } } } /** * Enters this monitor if the guard is satisfied. Blocks at most the given time acquiring the * lock, but does not wait for the guard to be satisfied.Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 42.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} static TestCondition create() { Lock lock = new ReentrantLock(); Condition condition = lock.newCondition(); return new TestCondition(lock, condition); } @Override public void await() throws InterruptedException { lock.lock(); try { condition.await(); } finally { lock.unlock(); } } @OverrideRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 31.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/DirectExecutorService.java
*/ @GuardedBy("lock") private int runningTasks = 0; @GuardedBy("lock") private boolean shutdown = false; @Override public void execute(Runnable command) { startTask(); try { command.run(); } finally { endTask(); } } @Override public boolean isShutdown() { synchronized (lock) { return shutdown; } }Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Apr 12 15:07:59 UTC 2025 - 3.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* always under a lock. */ private static final class SupplantableFuture implements Cancellable { private final ReentrantLock lock; @GuardedBy("lock") private Future<@Nullable Void> currentFuture; SupplantableFuture(ReentrantLock lock, Future<@Nullable Void> currentFuture) { this.lock = lock; this.currentFuture = currentFuture; }Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:49:49 UTC 2025 - 13K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lock/Smb2LockRequestTest.java
/** * Test class for Smb2LockRequest functionality */ @DisplayName("Smb2LockRequest Tests") class Smb2LockRequestTest { @Mock private Configuration mockConfig; @Mock private CIFSContext mockContext; @Mock private Smb2Lock mockLock; private byte[] testFileId; private Smb2Lock[] testLocks; private Smb2LockRequest request; @BeforeEachRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 25.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java
lock.encode(new byte[20], 0); // initialise fields by encoding to set pid etc (though not needed) setField(lock, "pid", 123); setField(lock, "byteOffset", 100L); setField(lock, "lengthInBytes", 200L); LockingAndXRange unlock = new LockingAndXRange(false); setField(unlock, "pid", 456); setField(unlock, "byteOffset", 300L); setField(unlock, "lengthInBytes", 400L);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
} }; private static final Supplier<Lock> LOCK_SUPPLER = new Supplier<Lock>() { @Override public Lock get() { return new ReentrantLock(); } }; private static final Supplier<Lock> FAIR_LOCK_SUPPLER = new Supplier<Lock>() { @Override public Lock get() { return new ReentrantLock(true); } };Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
} }; private static final Supplier<Lock> LOCK_SUPPLER = new Supplier<Lock>() { @Override public Lock get() { return new ReentrantLock(); } }; private static final Supplier<Lock> FAIR_LOCK_SUPPLER = new Supplier<Lock>() { @Override public Lock get() { return new ReentrantLock(true); } };Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.5K bytes - Viewed (0)