Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for Microseconds (3.11 sec)

  1. guava/src/com/google/common/util/concurrent/RateLimiter.java

      }
    
      /**
       * Reserves the given number of permits from this {@code RateLimiter} for future use, returning
       * the number of microseconds until the reservation can be consumed.
       *
       * @return time in microseconds to wait until the resource can be acquired, never negative
       */
      final long reserve(int permits) {
        checkPermits(permits);
        synchronized (mutex()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

      }
    
      /**
       * Reserves the given number of permits from this {@code RateLimiter} for future use, returning
       * the number of microseconds until the reservation can be consumed.
       *
       * @return time in microseconds to wait until the resource can be acquired, never negative
       */
      final long reserve(int permits) {
        checkPermits(permits);
        synchronized (mutex()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      public void testTryAcquire_overflow() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        assertTrue(limiter.tryAcquire(0, MICROSECONDS));
        stopwatch.sleepMillis(100);
        assertTrue(limiter.tryAcquire(Long.MAX_VALUE, MICROSECONDS));
      }
    
      public void testTryAcquire_negative() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        assertTrue(limiter.tryAcquire(5, 0, SECONDS));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      public void testTryAcquire_overflow() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        assertTrue(limiter.tryAcquire(0, MICROSECONDS));
        stopwatch.sleepMillis(100);
        assertTrue(limiter.tryAcquire(Long.MAX_VALUE, MICROSECONDS));
      }
    
      public void testTryAcquire_negative() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        assertTrue(limiter.tryAcquire(5, 0, SECONDS));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

      private var nextQueueName = 10000
      private var coordinatorWaiting = false
      private var coordinatorWakeUpAt = 0L
    
      /**
       * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we
       * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until
       * the already-requested ones are in service, otherwise we might create more threads than we need.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       *
       * <p>This always holds: {@code 0 <= permitsToTake <= storedPermits}
       */
      abstract long storedPermitsToWaitTime(double storedPermits, double permitsToTake);
    
      /**
       * Returns the number of microseconds during cool down that we have to wait to get a new permit.
       */
      abstract double coolDownIntervalMicros();
    
      /** Updates {@code storedPermits} and {@code nextFreeTicketMicros} based on the current time. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  7. docs/en/docs/async.md

    Instead of that, by being an "asynchronous" system, once finished, the task can wait in line a little bit (some microseconds) for the computer / program to finish whatever it went to do, and then come back to take the results and continue working with them.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 28 23:33:37 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  8. docs/en/docs/tutorial/bigger-applications.md

    So, behind the scenes, it will actually work as if everything was the same single app.
    
    ///
    
    /// check
    
    You don't have to worry about performance when including routers.
    
    This will take microseconds and will only happen at startup.
    
    So it won't affect performance. ⚡
    
    ///
    
    ### Include an `APIRouter` with a custom `prefix`, `tags`, `responses`, and `dependencies`
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  9. docs/fr/docs/async.md

    À la place, en étant "asynchrone", une fois terminée, une tâche peut légèrement attendre (quelques microsecondes) que l'ordinateur / le programme finisse ce qu'il était en train de faire, et revienne récupérer le résultat.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 25.4K bytes
    - Viewed (0)
  10. cmd/data-scanner.go

    	return &dynamicSleeper{
    		factor:    factor,
    		cycle:     make(chan struct{}),
    		maxSleep:  maxWait,
    		minSleep:  100 * time.Microsecond,
    		isScanner: isScanner,
    	}
    }
    
    // Timer returns a timer that has started.
    // When the returned function is called it will wait.
    func (d *dynamicSleeper) Timer(ctx context.Context) func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top