Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for atomically (0.11 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. doc/README.md

    unfinished release note work.
    
    To prepare the release notes for a release, run `relnote generate`.
    That will merge the `.md` files in `next` into a single file.
    Atomically (as close to it as possible) add that file to `_content/doc` directory
    of the website repository and remove the `doc/next` directory in this repository.
    
    To begin the next release development cycle, populate the contents of `next`
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Jul 22 17:55:04 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  3. 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)
  4. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

     * A helper which does some thread-safe operations for aggregate futures, which must be implemented
     * differently in GWT. Namely:
     *
     * <ul>
     *   <li>Lazily initializes a set of seen exceptions
     *   <li>Decrements a counter atomically
     * </ul>
     */
    @GwtCompatible(emulated = true)
    @ReflectionSupport(value = ReflectionSupport.Level.FULL)
    @ElementTypesAreNonnullByDefault
    abstract class AggregateFutureState<OutputT extends @Nullable Object>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. cmd/os-instrumented.go

    func init() {
    	// Inject metrics.
    	ioutilx.OsOpenFile = OpenFile
    	ioutilx.OpenFileDirectIO = OpenFileDirectIO
    	ioutilx.OsOpen = Open
    }
    
    type osMetrics struct {
    	// All fields must be accessed atomically and aligned.
    	operations [osMetricLast]uint64
    	latency    [osMetricLast]lockedLastMinuteLatency
    }
    
    // time an os action.
    func (o *osMetrics) time(s osMetric) func() {
    	startTime := time.Now()
    	return func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 15 01:09:38 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AggregateFutureState.java

     * A helper which does some thread-safe operations for aggregate futures, which must be implemented
     * differently in GWT. Namely:
     *
     * <ul>
     *   <li>Lazily initializes a set of seen exceptions
     *   <li>Decrements a counter atomically
     * </ul>
     */
    @GwtCompatible(emulated = true)
    @ReflectionSupport(value = ReflectionSupport.Level.FULL)
    @ElementTypesAreNonnullByDefault
    abstract class AggregateFutureState<OutputT extends @Nullable Object>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top