Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 66 for bursty (0.1 sec)

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

        }
    
        @Override
        double coolDownIntervalMicros() {
          return warmupPeriodMicros / maxPermits;
        }
      }
    
      /**
       * This implements a "bursty" RateLimiter, where storedPermits are translated to zero throttling.
       * The maximum number of permits that can be saved (when the RateLimiter is unused) is defined in
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          int oneSecWorthOfWork = rate;
          stopwatch.sleepMillis(rate * 1000);
          limiter.setRate(rate);
          long burst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
          // we allow one second worth of work to go in a burst (i.e. take less than a second)
          assertTrue(burst <= 1000);
          long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          int oneSecWorthOfWork = rate;
          stopwatch.sleepMillis(rate * 1000);
          limiter.setRate(rate);
          long burst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
          // we allow one second worth of work to go in a burst (i.e. take less than a second)
          assertTrue(burst <= 1000);
          long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
    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. internal/bucket/bandwidth/reader.go

    func (r *MonitoredReader) Read(buf []byte) (n int, err error) {
    	if r.throttle == nil {
    		return r.r.Read(buf)
    	}
    	if r.lastErr != nil {
    		err = r.lastErr
    		return
    	}
    	b := r.throttle.Burst()  // maximum available tokens
    	need := len(buf)         // number of bytes requested by caller
    	hdr := r.opts.HeaderSize // remaining header bytes
    	var tokens int           // number of tokens to request
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.3.md

    * Change default value of deleting-pods-burst to 1 ([#27606](https://github.com/kubernetes/kubernetes/pull/27606), [@gmarek](https://github.com/gmarek))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 84K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/Striped64.java

      transient volatile int busy;
    
      /** Package-private default constructor */
      Striped64() {}
    
      /** CASes the base field. */
      final boolean casBase(long cmp, long val) {
        return UNSAFE.compareAndSwapLong(this, baseOffset, cmp, val);
      }
    
      /** CASes the busy field from 0 to 1 to acquire lock. */
      final boolean casBusy() {
    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. src/main/resources/fess_indices/fess/tr/stopwords.txt

    acaba
    altmış
    altı
    ama
    ancak
    arada
    aslında
    ayrıca
    bana
    bazı
    belki
    ben
    benden
    beni
    benim
    beri
    beş
    bile
    bin
    bir
    birçok
    biri
    birkaç
    birkez
    birşey
    birşeyi
    biz
    bize
    bizden
    bizi
    bizim
    böyle
    böylece
    bu
    buna
    bunda
    bundan
    bunlar
    bunları
    bunların
    bunu
    bunun
    burada
    çok
    çünkü
    da
    daha
    dahi
    de
    defa
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Jul 19 06:31:02 UTC 2018
    - 1.5K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.2.md

    * Add support for running clusters on GCI ([#24893](https://github.com/kubernetes/kubernetes/pull/24893), [@andyzheng0831](https://github.com/andyzheng0831))
    * Trusty: Add retry in curl commands ([#24749](https://github.com/kubernetes/kubernetes/pull/24749), [@andyzheng0831](https://github.com/andyzheng0831))
    
    
    
    # v1.2.3
    
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Fri Dec 04 06:36:19 UTC 2020
    - 41.4K bytes
    - Viewed (0)
  9. tests/test_tutorial/test_sql_databases/test_tutorial001.py

                json={"name": "Spider-Boy", "age": 18, "secret_name": "Pedro Parqueador"},
            )
            assert response.status_code == 200, response.text
            response = client.post(
                "/heroes/", json={"name": "Rusty-Man", "secret_name": "Tommy Sharp"}
            )
            assert response.status_code == 200, response.text
    
            response = client.get("/heroes/")
            assert response.status_code == 200, response.text
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 09 19:44:42 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/hash/Striped64.java

      transient volatile int busy;
    
      /** Package-private default constructor */
      Striped64() {}
    
      /** CASes the base field. */
      final boolean casBase(long cmp, long val) {
        return UNSAFE.compareAndSwapLong(this, baseOffset, cmp, val);
      }
    
      /** CASes the busy field from 0 to 1 to acquire lock. */
      final boolean casBusy() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
Back to top