- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for compareAndSet (0.05 sec)
-
guava/src/com/google/common/util/concurrent/AtomicDouble.java
* @return {@code true} if successful. False return indicates that the actual value was not * bitwise equal to the expected value. */ public final boolean compareAndSet(double expect, double update) { return updater.compareAndSet(this, doubleToRawLongBits(expect), doubleToRawLongBits(update)); } /** * Atomically sets the value to the given updated value if the current value is <a
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 9.5K bytes - Viewed (0) -
src/main/java/jcifs/util/SimpleCircuitBreaker.java
if (current == State.OPEN) { long timeSinceLastFailure = System.currentTimeMillis() - lastFailureTime.get(); if (timeSinceLastFailure > timeoutMillis) { if (state.compareAndSet(State.OPEN, State.HALF_OPEN)) { stateChangeTime.set(System.currentTimeMillis()); halfOpenSuccesses.set(0);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 11.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java
for (double x : VALUES) { assertBitEquals(prev, aa.get(i)); assertFalse(aa.compareAndSet(i, unused, x)); assertBitEquals(prev, aa.get(i)); assertTrue(aa.compareAndSet(i, prev, x)); assertBitEquals(x, aa.get(i)); prev = x; } } } /** compareAndSet in one thread enables another waiting for value to succeed */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 14.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java
* @param update the new value * @return true if successful. False return indicates that the actual value was not equal to the * expected value. */ public final boolean compareAndSet(int i, double expect, double update) { return longs.compareAndSet(i, doubleToRawLongBits(expect), doubleToRawLongBits(update)); } /** * Atomically sets the element at position {@code i} to the given updated value if the current
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 10.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
* interrupt, yet it will still run, since interruptTask will leave the runner value null, * allowing the CAS below to succeed. */ Thread currentThread = Thread.currentThread(); if (!compareAndSet(null, currentThread)) { return; // someone else has run or is running. } boolean run = !isDone(); T result = null; Throwable error = null; try { if (run) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 10K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
AbstractFutureState<?> future, @Nullable Waiter expect, @Nullable Waiter update) { return waitersUpdater.compareAndSet(future, expect, update); } @Override boolean casListeners( AbstractFutureState<?> future, @Nullable Listener expect, Listener update) { return listenersUpdater.compareAndSet(future, expect, update); } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
AbstractFutureState<?> future, @Nullable Waiter expect, @Nullable Waiter update) { return waitersUpdater.compareAndSet(future, expect, update); } @Override boolean casListeners( AbstractFutureState<?> future, @Nullable Listener expect, Listener update) { return listenersUpdater.compareAndSet(future, expect, update); } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* other callers have added to it. * * This read is guaranteed to get us the right value because we only set this once (here). * * requireNonNull is safe because either our compareAndSet succeeded or it failed because * another thread did it for us. */ seenExceptionsLocal = requireNonNull(seenExceptionsField); } return seenExceptionsLocal; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
for (int i = 0; i < 10; i++) { int expectedCount = i; list.add( new Runnable() { @Override public void run() { integer.compareAndSet(expectedCount, expectedCount + 1); } }, directExecutor()); } list.execute(); assertEquals(10, integer.get()); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 4.7K bytes - Viewed (0) -
src/main/java/jcifs/util/AuthenticationRateLimiter.java
long windowStart = currentWindowStart.get(); // Check if we need to reset the window (1 minute window) if (now - windowStart > 60000) { currentWindowStart.compareAndSet(windowStart, now); globalAttemptsInCurrentWindow.set(0); } int attempts = globalAttemptsInCurrentWindow.incrementAndGet(); return attempts <= maxGlobalAttemptsPerMinute; }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 15.1K bytes - Viewed (0)