Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 146 for atomic (0.29 sec)

  1. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

    import static java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater;
    import static java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.j2objc.annotations.ReflectionSupport;
    import java.util.Set;
    import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
    import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
    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)
  2. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

        checkHelperVersion(NO_ATOMIC_FIELD_UPDATER, "SynchronizedAtomicHelper");
    
        // Run the corresponding FuturesTest test method in a new classloader that disallows
        // certain core jdk classes.
        ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();
        Thread.currentThread().setContextClassLoader(NO_ATOMIC_FIELD_UPDATER);
        try {
          runTestMethod(NO_ATOMIC_FIELD_UPDATER);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Oct 10 19:45:10 GMT 2022
    - 5.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java

        outer:
        while (true) {
          AtomicLong atomic = map.get(key);
          if (atomic == null) {
            atomic = map.putIfAbsent(key, new AtomicLong(delta));
            if (atomic == null) {
              return delta;
            }
            // atomic is now non-null; fall through
          }
    
          while (true) {
            long oldValue = atomic.get();
            if (oldValue == 0L) {
    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)
  4. android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java

    import static org.junit.Assert.assertThrows;
    
    import com.google.common.util.concurrent.GeneratedMonitorTest.FlagGuard;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReference;
    import junit.framework.TestCase;
    
    /**
     * Supplemental tests for {@link Monitor}.
     *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /** Test case for {@link TrustedListenableFutureTask}. */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AtomicsTest.java

    import java.util.concurrent.atomic.AtomicReferenceArray;
    import junit.framework.TestCase;
    
    /**
     * Unit test for {@link Atomics}.
     *
     * @author Kurt Alfred Kluever
     */
    public class AtomicsTest extends TestCase {
    
      private static final Object OBJECT = new Object();
    
      public void testNewReference() throws Exception {
        assertEquals(null, Atomics.newReference().get());
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 2.5K bytes
    - Viewed (1)
  7. android/guava-tests/test/com/google/common/util/concurrent/AtomicsTest.java

    import java.util.concurrent.atomic.AtomicReferenceArray;
    import junit.framework.TestCase;
    
    /**
     * Unit test for {@link Atomics}.
     *
     * @author Kurt Alfred Kluever
     */
    public class AtomicsTest extends TestCase {
    
      private static final Object OBJECT = new Object();
    
      public void testNewReference() throws Exception {
        assertEquals(null, Atomics.newReference().get());
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 2.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

        checkHelperVersion(NO_ATOMIC_FIELD_UPDATER, "SynchronizedAtomicHelper");
    
        // Run the corresponding FuturesTest test method in a new classloader that disallows
        // certain core jdk classes.
        ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();
        Thread.currentThread().setContextClassLoader(NO_ATOMIC_FIELD_UPDATER);
        try {
          runTestMethod(NO_ATOMIC_FIELD_UPDATER);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Oct 10 19:45:10 GMT 2022
    - 5.9K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /** Test case for {@link TrustedListenableFutureTask}. */
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        /**
         * Constructor for the TOMBSTONE, avoids use of ATOMIC_HELPER in case this class is loaded
         * before the ATOMIC_HELPER. Apparently this is possible on some android platforms.
         */
        Waiter(boolean unused) {}
    
        Waiter() {
          // avoid volatile write, write is made visible by subsequent CAS on waiters field
          ATOMIC_HELPER.putThread(this, Thread.currentThread());
        }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
Back to top