Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 312 for Atomics (0.1 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/AtomicsTest.java

      private static final Object OBJECT = new Object();
    
      public void testNewReference() throws Exception {
        assertThat(Atomics.newReference().get()).isNull();
      }
    
      public void testNewReference_withInitialValue() throws Exception {
        assertThat(Atomics.newReference(null).get()).isNull();
        assertEquals(OBJECT, Atomics.newReference(OBJECT).get());
      }
    
      public void testNewReferenceArray_withLength() throws Exception {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 2.8K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/AtomicsTest.java

      private static final Object OBJECT = new Object();
    
      public void testNewReference() throws Exception {
        assertThat(Atomics.newReference().get()).isNull();
      }
    
      public void testNewReference_withInitialValue() throws Exception {
        assertThat(Atomics.newReference(null).get()).isNull();
        assertEquals(OBJECT, Atomics.newReference(OBJECT).get());
      }
    
      public void testNewReferenceArray_withLength() throws Exception {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 2.8K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/hash/BloomFilterStrategies.java

        long bitSize() {
          return (long) data.length() * Long.SIZE;
        }
    
        /**
         * Number of set bits (1s).
         *
         * <p>Note that because of concurrent set calls and uses of atomics, this bitCount is a (very)
         * close *estimate* of the actual number of bits set. It's not possible to do better than an
         * estimate without locking. Note that the number, if not exactly accurate, is *always*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 10.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/hash/BloomFilter.java

     * generated today may <i>not</i> be readable by a binary that was compiled 6 months ago).
     *
     * <p>As of Guava 23.0, this class is thread-safe and lock-free. It internally uses atomics and
     * compare-and-swap to ensure correctness when multiple threads are used to access it.
     *
     * @param <T> the type of instances that the {@code BloomFilter} accepts
     * @author Dimitris Andreou
     * @author Kevin Bourrillion
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 10 22:28:12 GMT 2026
    - 27.6K bytes
    - Click Count (0)
  5. doc/go_mem.html

    twice.
    </p>
    
    <h3 id="atomic">Atomic Values</h3>
    
    <p>
    The APIs in the <a href="/pkg/sync/atomic/"><code>sync/atomic</code></a>
    package are collectively “atomic operations”
    that can be used to synchronize the execution of different goroutines.
    If the effect of an atomic operation <i>A</i> is observed by atomic operation <i>B</i>,
    then <i>A</i> is synchronized before <i>B</i>.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Aug 05 15:41:37 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.concurrent.locks.LockSupport;
    import junit.framework.AssertionFailedError;
    import junit.framework.TestCase;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.concurrent.locks.LockSupport;
    import junit.framework.AssertionFailedError;
    import junit.framework.TestCase;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

    import java.util.concurrent.ScheduledThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReference;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

    import java.util.concurrent.ScheduledThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReference;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  10. docs/bigdata/README.md

    the connector to use S3 and other S3-compatible object stores such as MinIO. MapReduce workloads typically interact with object stores in the same way they do with HDFS. These workloads rely on HDFS atomic rename functionality to complete writing data to the datastore. Object storage operations are atomic by nature and they do not require/implement rename API. The default S3A committer emulates renames through copy and delete APIs. This interaction pattern causes significant loss of performance because...
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 14.7K bytes
    - Click Count (0)
Back to Top