Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 477 for limiter (0.16 sec)

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

        RateLimiter limiter = RateLimiter.create(Double.POSITIVE_INFINITY, stopwatch);
        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();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 21.6K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        RateLimiter limiter = RateLimiter.create(Double.POSITIVE_INFINITY, stopwatch);
        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();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 21.6K bytes
    - Viewed (0)
  3. src/runtime/mgclimit.go

    func (l *gcCPULimiterState) limiting() bool {
    	return l.enabled.Load()
    }
    
    // startGCTransition notifies the limiter of a GC transition.
    //
    // This call takes ownership of the limiter and disables all other means of
    // updating the limiter. Release ownership by calling finishGCTransition.
    //
    // It is safe to call concurrently with other operations.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 22:07:41 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * target} object, enforcing the specified time limit on each call. This time-limited delegation
       * is also performed for calls to {@link Object#equals}, {@link Object#hashCode}, and {@link
       * Object#toString}.
       *
       * <p>If the target method call finishes before the limit is reached, the return value or
       * exception is propagated to the caller exactly as-is. If, on the other hand, the time limit is
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  5. src/runtime/export_test.go

    	return l
    }
    
    func (l *GCCPULimiter) Fill() uint64 {
    	return l.limiter.bucket.fill
    }
    
    func (l *GCCPULimiter) Capacity() uint64 {
    	return l.limiter.bucket.capacity
    }
    
    func (l *GCCPULimiter) Overflow() uint64 {
    	return l.limiter.overflow
    }
    
    func (l *GCCPULimiter) Limiting() bool {
    	return l.limiter.limiting()
    }
    
    func (l *GCCPULimiter) NeedUpdate(now int64) bool {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:50:53 UTC 2024
    - 46.1K bytes
    - Viewed (0)
  6. pkg/controller/nodelifecycle/scheduler/rate_limited_queue_test.go

    	fakeAlways := flowcontrol.NewFakeAlwaysRateLimiter()
    	qps := evictor.limiter.QPS()
    	if qps != fakeAlways.QPS() {
    		t.Fatalf("QPS does not match create one: %v instead of %v", qps, fakeAlways.QPS())
    	}
    
    	evictor.SwapLimiter(0)
    	qps = evictor.limiter.QPS()
    	fakeNever := flowcontrol.NewFakeNeverRateLimiter()
    	if qps != fakeNever.QPS() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 17:40:33 UTC 2023
    - 10K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       * spread over each second. When the incoming request rate exceeds {@code permitsPerSecond} the
       * rate limiter will release one permit every {@code (1.0 / permitsPerSecond)} seconds. When the
       * rate limiter is unused, bursts of up to {@code permitsPerSecond} permits will be allowed, with
       * subsequent requests being smoothly limited at the stable rate of {@code permitsPerSecond}.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/RateLimiter.java

       * spread over each second. When the incoming request rate exceeds {@code permitsPerSecond} the
       * rate limiter will release one permit every {@code (1.0 / permitsPerSecond)} seconds. When the
       * rate limiter is unused, bursts of up to {@code permitsPerSecond} permits will be allowed, with
       * subsequent requests being smoothly limited at the stable rate of {@code permitsPerSecond}.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 21.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    	if limiter := pl.Spec.Limited; limiter != nil {
    		return limiter.NominalConcurrencyShares, limiter.LendablePercent, limiter.BorrowingLimitPercent
    	}
    	limiter := pl.Spec.Exempt
    	var nominalConcurrencyShares int32
    	if limiter.NominalConcurrencyShares != nil {
    		nominalConcurrencyShares = *limiter.NominalConcurrencyShares
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  10. src/runtime/metrics/description.go

    			"allocs-by-size and frees-by-size.",
    		Kind:       KindUint64,
    		Cumulative: true,
    	},
    	{
    		Name: "/gc/limiter/last-enabled:gc-cycle",
    		Description: "GC cycle the last time the GC CPU limiter was enabled. " +
    			"This metric is useful for diagnosing the root cause of an out-of-memory " +
    			"error, because the limiter trades memory for CPU time when the GC's CPU " +
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Dec 06 17:59:12 UTC 2023
    - 19.6K bytes
    - Viewed (0)
Back to top