Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 132 for Acquire (0.06 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        limiter.acquire(Integer.MAX_VALUE / 4);
        limiter.acquire(Integer.MAX_VALUE / 2);
        limiter.acquire(Integer.MAX_VALUE);
        assertEvents("R0.00", "R0.00", "R0.00"); // no wait, infinite rate!
    
        limiter.setRate(2.0);
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        assertEvents(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 22K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        limiter.acquire(Integer.MAX_VALUE / 4);
        limiter.acquire(Integer.MAX_VALUE / 2);
        limiter.acquire(Integer.MAX_VALUE);
        assertEvents("R0.00", "R0.00", "R0.00"); // no wait, infinite rate!
    
        limiter.setRate(2.0);
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        assertEvents(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 22K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

     *
     * <p>Deadlocks can arise when locks are acquired in an order that forms a cycle. In a simple
     * example involving two locks and two threads, deadlock occurs when one thread acquires Lock A, and
     * then Lock B, while another thread acquires Lock B, and then Lock A:
     *
     * <pre>
     * Thread1: acquire(LockA) --X acquire(LockB)
     * Thread2: acquire(LockB) --X acquire(LockA)
     * </pre>
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

         * <p>To avoid races between threads doing release and acquire, we transition to the final state
         * in two steps. One thread will successfully CAS from RUNNING to COMPLETING, that thread will
         * then set the result of the computation, and only then transition to COMPLETED, CANCELLED, or
         * INTERRUPTED.
         *
         * <p>We don't use the integer argument passed between acquire methods so we pass around a -1
         * everywhere.
         */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

         * <p>To avoid races between threads doing release and acquire, we transition to the final state
         * in two steps. One thread will successfully CAS from RUNNING to COMPLETING, that thread will
         * then set the result of the computation, and only then transition to COMPLETED, CANCELLED, or
         * INTERRUPTED.
         *
         * <p>We don't use the integer argument passed between acquire methods so we pass around a -1
         * everywhere.
         */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        // Put a floor on the keep alive duration, otherwise cleanup will spin loop.
        require(keepAliveDuration > 0L) { "keepAliveDuration <= 0: $keepAliveDuration" }
      }
    
      fun idleConnectionCount(): Int =
        connections.count {
          it.withLock { it.calls.isEmpty() }
        }
    
      fun connectionCount(): Int = connections.size
    
      /**
       * Attempts to acquire a recycled connection to [address] for [call]. Returns the connection if it
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 11.1K bytes
    - Click Count (0)
  7. docs/en/docs/deployment/https.md

    * Nginx
    * HAProxy
    
    ## Let's Encrypt { #lets-encrypt }
    
    Before Let's Encrypt, these **HTTPS certificates** were sold by trusted third parties.
    
    The process to acquire one of these certificates used to be cumbersome, require quite some paperwork and the certificates were quite expensive.
    
    But then **[Let's Encrypt](https://letsencrypt.org/)** was created.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 14K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java

        //                                                                    ================
    
        /**
         * Attempts to acquire a distributed lock for the specified operation.
         *
         * @param operationName the operation name used as the lock document ID.
         * @return {@code true} if the lock was acquired.
         */
        public boolean tryStartOperation(final String operationName) {
            return tryStartOperation(operationName, null);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 33.3K bytes
    - Click Count (0)
  9. docs/en/docs/advanced/events.md

    ///
    
    ### `startup` and `shutdown` together { #startup-and-shutdown-together }
    
    There's a high chance that the logic for your *startup* and *shutdown* is connected, you might want to start something and then finish it, acquire a resource and then release it, etc.
    
    Doing that in separated functions that don't share logic or variables together is more difficult as you would need to store values in global variables or similar tricks.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 7.8K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

       * cancelled without a call to {@code cancel}, such as by calling {@code
       * setFuture(cancelledFuture)}.
       *
       * <p>Beware of completing a future while holding a lock. Its listeners may do slow work or
       * acquire other locks, risking deadlocks.
       */
      @CanIgnoreReturnValue
      @Override
      public boolean cancel(boolean mayInterruptIfRunning) {
        @RetainedLocalRef Object localValue = value();
        boolean rValue = false;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
Back to Top