Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for atomically (0.03 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java

            }
    
            try {
                final URI uri = new URI(url);
                final String host = uri.getHost();
                if (host == null) {
                    return;
                }
    
                // Atomically get or create the AtomicLong for this host using Cache.get()
                // This ensures thread-safe, atomic get-or-create behavior
                // Initialize with 0 to mark uninitialized state
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AtomicLongMap.java

    import java.util.function.LongBinaryOperator;
    import java.util.function.LongUnaryOperator;
    import org.jspecify.annotations.Nullable;
    
    /**
     * 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Oct 10 23:13:45 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

      private val tags = AtomicReference(originalRequest.tags)
    
      override fun timeout(): Timeout = timeout
    
      override fun addEventListener(eventListener: EventListener) {
        // Atomically replace the current eventListener with a composite one.
        do {
          val previous = this.eventListener
        } while (!eventListenerUpdater.compareAndSet(this, previous, previous + eventListener))
      }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/cache/CacheBuilder.java

      }
    
      Supplier<? extends StatsCounter> getStatsCounterSupplier() {
        return statsCounterSupplier;
      }
    
      /**
       * Builds a cache, which either returns an already-loaded value for a given key or atomically
       * computes or retrieves it using the supplied {@code CacheLoader}. If another thread is currently
       * loading the value for this key, simply waits for that thread to finish and returns its loaded
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 51.9K bytes
    - Viewed (0)
  5. guava/src/com/google/common/cache/CacheBuilder.java

      }
    
      Supplier<? extends StatsCounter> getStatsCounterSupplier() {
        return statsCounterSupplier;
      }
    
      /**
       * Builds a cache, which either returns an already-loaded value for a given key or atomically
       * computes or retrieves it using the supplied {@code CacheLoader}. If another thread is currently
       * loading the value for this key, simply waits for that thread to finish and returns its loaded
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 51.6K bytes
    - Viewed (0)
Back to top