- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for decrementAndGet (1.4 sec)
-
guava-tests/test/com/google/common/util/concurrent/AtomicLongMapTest.java
assertEquals(0L, map.get(key)); assertFalse(map.containsKey(key)); assertEquals(-1L, map.decrementAndGet(key)); assertEquals(-1L, map.get(key)); assertEquals(0L, map.incrementAndGet(key)); assertEquals(0L, map.get(key)); assertTrue(map.containsKey(key)); assertEquals(-1L, map.decrementAndGet(key)); assertEquals(-1L, map.get(key)); } public void testGetAndDecrement() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 17.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapTest.java
assertEquals(0L, map.get(key)); assertFalse(map.containsKey(key)); assertEquals(-1L, map.decrementAndGet(key)); assertEquals(-1L, map.get(key)); assertEquals(0L, map.incrementAndGet(key)); assertEquals(0L, map.get(key)); assertTrue(map.containsKey(key)); assertEquals(-1L, map.decrementAndGet(key)); assertEquals(-1L, map.get(key)); } public void testGetAndDecrement() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 17.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
// by executing on the same thread. if (executorService.isShutdown) { for (i in 0 until executableCalls.size) { val asyncCall = executableCalls[i] asyncCall.callsPerHost.decrementAndGet() this.withLock { runningAsyncCalls.remove(asyncCall) } asyncCall.failRejected() } idleCallback?.run() } else {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
case 0: map.incrementAndGet(key); threadSum++; break; case 1: map.decrementAndGet(key); threadSum--; break; case 2: map.addAndGet(key, delta); threadSum += delta;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 4.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
seenExceptionsUpdater.compareAndSet(state, expect, update); } @Override int decrementAndGetRemainingCount(AggregateFutureState<?> state) { return remainingCountUpdater.decrementAndGet(state); } } private static final class SynchronizedAtomicHelper extends AtomicHelper { @Override void compareAndSetSeenExceptions(
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 8.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
case 0: map.incrementAndGet(key); threadSum++; break; case 1: map.decrementAndGet(key); threadSum--; break; case 2: map.addAndGet(key, delta); threadSum += delta;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 4.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
count = new AtomicInteger(1); } public int increment() { return count.incrementAndGet(); } public int decrement() { return count.decrementAndGet(); } } public enum StatsAction { ACCESSED, // ACCESS_EXCEPTION, // CHILD_URL, // CHILD_URLS, // EVALUATED, // EXCEPTION, //
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java
return addAndGet(key, 1); } /** * Decrements by one the value currently associated with {@code key}, and returns the new value. */ @CanIgnoreReturnValue public long decrementAndGet(K key) { return addAndGet(key, -1); } /** * Adds {@code delta} to the value currently associated with {@code key}, and returns the new * value. */ @CanIgnoreReturnValue
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 14.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
public void release () { release(true); } /** * @param track */ public void release ( boolean track ) { long usage = this.usageCount.decrementAndGet(); if ( log.isTraceEnabled() ) { log.trace("Release tree " + usage + " " + this); } if ( track && this.traceResource ) { synchronized ( this.releases ) {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Thu Jan 05 13:06:39 GMT 2023 - 29.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
removeFromReplica(replica, replicatedMaxValue); } private static void removeFromReplica(Map<Integer, AtomicInteger> replica, int value) { AtomicInteger numOccur = replica.get(value); if (numOccur.decrementAndGet() == 0) { replica.remove(value); } } private static void assertIntact(MinMaxPriorityQueue<?> q) { if (!q.isIntact()) { fail("State " + Arrays.toString(q.toArray())); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 36.1K bytes - Viewed (0)