- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 143 for Lock (0.12 sec)
-
android/guava-tests/test/com/google/common/cache/CacheTesting.java
for (Segment<?, ?> segment : map.segments) { drainRecencyQueue(segment); } } } static void drainRecencyQueue(Segment<?, ?> segment) { segment.lock(); try { segment.cleanUp(); } finally { segment.unlock(); } } static void drainReferenceQueues(Cache<?, ?> cache) { if (hasLocalCache(cache)) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 16.7K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00 }; private static final Logger log = LoggerFactory.getLogger(NameServiceClientImpl.class); private final Object LOCK = new Object(); private int nbnsIndex = 0; private final Map<Name, CacheEntry> addressCache = new HashMap<>(); private final Set<Name> inFlightLookups = new HashSet<>();
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Aug 14 14:26:22 GMT 2022 - 38.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
} @Override public E element() { assertTrue(Thread.holdsLock(mutex)); return delegate.element(); } @Override public Iterator<E> iterator() { // We explicitly don't lock for iterator() assertFalse(Thread.holdsLock(mutex)); return delegate.iterator(); } @Override public int size() { assertTrue(Thread.holdsLock(mutex)); return delegate.size();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 7.4K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 18.9K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/LegacyRepositorySystem.java
url = "file://" + url.substring("file:".length()); } // So now we have an url of the form file://<path> // We want to eliminate any relative path nonsense and lock down the path so we // need to fully resolve it before any submodules use the path. This can happen // when you are using a custom settings.xml that contains a relative path entry
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Sep 14 11:48:15 GMT 2023 - 31.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java
break; case SMB2_READ: c = "SMB2_READ"; break; case SMB2_WRITE: c = "SMB2_WRITE"; break; case SMB2_LOCK: c = "SMB2_LOCK"; break; case SMB2_IOCTL: c = "SMB2_IOCTL"; break; case SMB2_CANCEL: c = "SMB2_CANCEL"; break;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Sep 30 10:47:31 GMT 2018 - 19.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
} @Override public E element() { assertTrue(Thread.holdsLock(mutex)); return delegate.element(); } @Override public Iterator<E> iterator() { // We explicitly don't lock for iterator() assertFalse(Thread.holdsLock(mutex)); return delegate.iterator(); } @Override public int size() { assertTrue(Thread.holdsLock(mutex)); return delegate.size();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 4.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
} @Override public E element() { assertTrue(Thread.holdsLock(mutex)); return delegate.element(); } @Override public Iterator<E> iterator() { // We explicitly don't lock for iterator() assertFalse(Thread.holdsLock(mutex)); return delegate.iterator(); } @Override public int size() { assertTrue(Thread.holdsLock(mutex)); return delegate.size();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 7.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
* cancelled without a call to {@code cancel}, such as by calling {@code * setFuture(cancelledFuture)}. * * <p>Beware of completing a future while holding a lock. Its listeners may do slow work or * acquire other locks, risking deadlocks. */ @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { Object localValue = value;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/SubscriberRegistry.java
"missing event subscriber for an annotated method. Is " + listener + " registered?"); } // don't try to remove the set if it's empty; that can't be done safely without a lock // anyway, if the set is empty it'll just be wrapping an array of length 0 } } @VisibleForTesting Set<Subscriber> getSubscribersForTesting(Class<?> eventType) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 10.5K bytes - Viewed (0)