- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for atomically (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0)