Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for atomically (0.1 sec)

  1. guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java

      }
    
      /**
       * Atomically adds the given value to the element at index {@code i}.
       *
       * @param i the index
       * @param delta the value to add
       * @return the previous value
       */
      @CanIgnoreReturnValue
      public final double getAndAdd(int i, double delta) {
        return getAndAccumulate(i, delta, Double::sum);
      }
    
      /**
       * Atomically adds the given value to the element at index {@code i}.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AtomicLongMap.java

    import java.util.function.LongBinaryOperator;
    import java.util.function.LongUnaryOperator;
    import javax.annotation.CheckForNull;
    
    /**
     * A map containing {@code long} values that can be atomically updated. While writes to a
     * traditional {@code Map} rely on {@code put(K, V)}, the typical mechanism for writing to this map
     * is {@code addAndGet(K, long)}, which adds a {@code long} to the value currently associated with
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. cmd/bucket-metadata-sys.go

    	}
    }
    
    // Set - sets a new metadata in-memory.
    // Only a shallow copy is saved and fields with references
    // cannot be modified without causing a race condition,
    // so they should be replaced atomically and not appended to, etc.
    // Data is not persisted to disk.
    func (sys *BucketMetadataSys) Set(bucket string, meta BucketMetadata) {
    	if !isMinioMetaBucketName(bucket) {
    		sys.Lock()
    		sys.metadataMap[bucket] = meta
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java

    import java.util.Map.Entry;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.atomic.AtomicLong;
    import javax.annotation.CheckForNull;
    
    /**
     * A map containing {@code long} values that can be atomically updated. While writes to a
     * traditional {@code Map} rely on {@code put(K, V)}, the typical mechanism for writing to this map
     * is {@code addAndGet(K, long)}, which adds a {@code long} to the value currently associated with
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/Striped64.java

     */
    @SuppressWarnings({"SunApi", "removal"}) // b/345822163
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    abstract class Striped64 extends Number {
      /*
       * This class maintains a lazily-initialized table of atomically
       * updated variables, plus an extra "base" field. The table size
       * is a power of two. Indexing uses masked per-thread hash codes.
       * Nearly all declarations in this class are package-private,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. tensorflow/c/eager/c_api_experimental.h

    // Monitoring Counter APIs.
    // These APIs de-templated monitoring Counter for swig.
    
    typedef struct TFE_MonitoringCounterCell TFE_MonitoringCounterCell;
    
    // Atomically increments the value of the cell. The value must be non-negative.
    TF_CAPI_EXPORT extern void TFE_MonitoringCounterCellIncrementBy(
        TFE_MonitoringCounterCell* cell, int64_t value);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

           * This lock is used to ensure safe and correct cancellation, it ensures that a new task is
           * not scheduled while a cancel is ongoing. Also it protects the currentFuture variable to
           * ensure that it is assigned atomically with being scheduled.
           */
          private final ReentrantLock lock = new ReentrantLock();
    
          /** The future that represents the next execution of this task. */
          @GuardedBy("lock")
          @CheckForNull
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/hash/Striped64.java

     */
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    @SuppressWarnings({"SunApi", "removal"}) // b/345822163
    abstract class Striped64 extends Number {
      /*
       * This class maintains a lazily-initialized table of atomically
       * updated variables, plus an extra "base" field. The table size
       * is a power of two. Indexing uses masked per-thread hash codes.
       * Nearly all declarations in this class are package-private,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

          E e;
          while (n < maxElements && (e = q.poll()) != null) {
            c.add(e);
            ++n;
          }
          return n;
        } finally {
          monitor.leave();
        }
      }
    
      /**
       * Atomically removes all of the elements from this queue. The queue will be empty after this call
       * returns.
       */
      @Override
      public void clear() {
        final Monitor monitor = this.monitor;
        monitor.enter();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 07 21:36:32 UTC 2024
    - 19K bytes
    - Viewed (0)
  10. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

        final Monitor monitor = this.monitor;
        monitor.enter();
        try {
          return super.toString();
        } finally {
          monitor.leave();
        }
      }
    
      /**
       * Atomically removes all of the elements from this queue. The queue will be empty after this call
       * returns.
       */
      @Override
      public void clear() {
        final E[] items = this.items;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 19 19:24:36 UTC 2023
    - 22.5K bytes
    - Viewed (0)
Back to top