Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for compareAndSet (0.28 sec)

  1. 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)
  2. 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)
  3. 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)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt

          }
        } finally {
          readCompleteLatch.countDown()
        }
      }
    
      abstract fun listSource(): Source
    
      override fun ensureLoaded() {
        if (!listRead.get() && listRead.compareAndSet(false, true)) {
          readTheListUninterruptibly()
        } else {
          try {
            readCompleteLatch.await()
          } catch (_: InterruptedException) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  5. android/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)
  6. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

          executionList.add(listener, exec);
    
          // When a listener is first added, we run a task that will wait for the delegate to finish,
          // and when it is done will run the listeners.
          if (hasListeners.compareAndSet(false, true)) {
            if (delegate.isDone()) {
              // If the delegate is already done, run the execution list immediately on the current
              // thread.
              executionList.execute();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 7.5K bytes
    - Viewed (0)
Back to top