Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for atomically (0.09 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. 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)
  4. 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)
  5. 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)
  6. 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)
  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. cmd/bucket-metadata.go

    	BucketTargetsConfigUpdatedAt     time.Time
    	BucketTargetsConfigMetaUpdatedAt time.Time
    	// Add a new UpdatedAt field and update lastUpdate function
    
    	// Unexported fields. Must be updated atomically.
    	policyConfig           *policy.BucketPolicy
    	notificationConfig     *event.Config
    	lifecycleConfig        *lifecycle.Lifecycle
    	objectLockConfig       *objectlock.Config
    	versioningConfig       *versioning.Versioning
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
Back to top