Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for bursty (0.05 sec)

  1. 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)
  2. 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. 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)
  4. istioctl/pkg/cli/context.go

    		// We are running a one-off command locally, so we don't need to worry too much about rate limiting
    		// Bumping this up greatly decreases install time
    		config.QPS = 50
    		config.Burst = 100
    		config.Impersonate = impersonateConfig
    	})
    	if err != nil {
    		return nil, err
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 23 19:31:32 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    public final class InterruptibleTaskTest extends TestCase {
    
      // Regression test for a deadlock where a task could be stuck busy waiting for the task to
      // transition to DONE
      public void testInterruptThrows() throws Exception {
        final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1);
        InterruptibleTask<@Nullable Void> task =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. tests/test_tutorial/test_sql_databases/test_tutorial002.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
    - 19.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

          if (compareAndSet(currentRunner, blocker)) {
            // Thread.interrupt can throw arbitrary exceptions due to the nio InterruptibleChannel API
            // This will make sure that tasks don't get stuck busy waiting.
            // Some of this is fixed in jdk11 (see https://bugs.openjdk.java.net/browse/JDK-8198692) but
            // not all.  See the test cases for examples on how this can happen.
            try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  8. docs/tr/docs/python-types.md

    {!../../docs_src/python_types/tutorial002.py!}
    ```
    
    Bu, aşağıdaki gibi varsayılan değerleri bildirmekle aynı şey değildir:
    
    ```Python
        first_name="john", last_name="doe"
    ```
    
    Bu tamamen farklı birşey
    
    İki nokta üst üste (`:`) kullanıyoruz , eşittir (`=`) değil.
    
    Normalde tip belirteçleri eklemek, kod üzerinde olacakları değiştirmez.
    
    Şimdi programı sıfırdan birdaha yazdığınızı hayal edin.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/server.go

    func buildKubeClient(kubeConfig string) (kube.Client, error) {
    	// Used by validation
    	kubeRestConfig, err := kube.DefaultRestConfig(kubeConfig, "", func(config *rest.Config) {
    		config.QPS = 80
    		config.Burst = 160
    	})
    	if err != nil {
    		return nil, fmt.Errorf("failed creating kube config: %v", err)
    	}
    
    	client, err := kube.NewClient(kube.NewClientConfigForRestConfig(kubeRestConfig), "")
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  10. cmd/peer-rest-server.go

    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    	err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top