Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 362 for sharding (0.07 sec)

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

          limiter.acquire(); // #5
        }
        stopwatch.sleepMillis(4250); // #6, back to cold state (warmup period + repay last acquire)
        for (int i = 0; i < 11; i++) {
          limiter.acquire(); // #7, showing off the warmup starting from totally cold
        }
    
        // make sure the areas (times) remain the same, while permits are different
        assertEvents(
            "R0.00, R1.38, R1.13, R0.88, R0.63, R0.50, R0.50, R0.50", // #1
    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. android/guava/src/com/google/common/reflect/TypeResolver.java

            Type[] resolvedBounds = new TypeResolver(forDependants).resolveTypes(bounds);
            /*
             * We'd like to simply create our own TypeVariable with the newly resolved bounds. There's
             * just one problem: Starting with JDK 7u51, the JDK TypeVariable's equals() method doesn't
             * recognize instances of our TypeVariable implementation. This is a problem because users
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 10 19:45:10 UTC 2022
    - 24.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          limiter.acquire(); // #5
        }
        stopwatch.sleepMillis(4250); // #6, back to cold state (warmup period + repay last acquire)
        for (int i = 0; i < 11; i++) {
          limiter.acquire(); // #7, showing off the warmup starting from totally cold
        }
    
        // make sure the areas (times) remain the same, while permits are different
        assertEvents(
            "R0.00, R1.38, R1.13, R0.88, R0.63, R0.50, R0.50, R0.50", // #1
    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-testlib/src/com/google/common/testing/EqualsTester.java

     *       <i>j</i><sup>th</sup> item in the <i>i</i><sup>th</sup> equality group, where both equality
     *       groups and the items within equality groups are numbered starting from 1. When either a
     *       constructor argument or an equal object is provided, that becomes group 1.
     * </ul>
     *
     * @author Jim McMaster
     * @author Jige Yu
     * @since 10.0
     */
    @GwtCompatible
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 31 19:11:50 UTC 2023
    - 6K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

              executor.execute(
                  () -> {
                    try {
                      startUp();
                      notifyStarted();
                      // If stopAsync() is called while starting we may be in the STOPPING state in
                      // which case we should skip right down to shutdown.
                      if (isRunning()) {
                        try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. internal/http/listener.go

    	NoDelay     bool             // Indicates callers to enable TCP_NODELAY on the net.Conn
    	Interface   string           // This is a VRF device passed via `--interface` flag
    	Trace       func(msg string) // Trace when starting.
    }
    
    // ForWebsocket returns TCPOptions valid for websocket net.Conn
    func (t TCPOptions) ForWebsocket() TCPOptions {
    	return TCPOptions{
    		UserTimeout: t.UserTimeout,
    		Interface:   t.Interface,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/testing/EqualsTester.java

     *       <i>j</i><sup>th</sup> item in the <i>i</i><sup>th</sup> equality group, where both equality
     *       groups and the items within equality groups are numbered starting from 1. When either a
     *       constructor argument or an equal object is provided, that becomes group 1.
     * </ul>
     *
     * @author Jim McMaster
     * @author Jige Yu
     * @since 10.0
     */
    @GwtCompatible
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 31 19:11:50 UTC 2023
    - 6K bytes
    - Viewed (0)
  8. guava/src/com/google/common/cache/Cache.java

       * <p>Among the improvements that this method and {@code LoadingCache.get(K)} both provide are:
       *
       * <ul>
       *   <li>{@linkplain LoadingCache#get(Object) awaiting the result of a pending load} rather than
       *       starting a redundant one
       *   <li>eliminating the error-prone caching boilerplate
       *   <li>tracking load {@linkplain #stats statistics}
       * </ul>
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Aug 07 02:38:22 UTC 2022
    - 7.9K bytes
    - Viewed (0)
  9. docs/em/docs/deployment/server-workers.md

    ## ๐Ÿƒ ๐Ÿ โฎ๏ธ Uvicorn ๐Ÿ‘จโ€๐Ÿญ
    
    โคด๏ธ ๐Ÿ‘† ๐Ÿ’ช ๐Ÿƒ ๐Ÿ โฎ๏ธ:
    
    <div class="termy">
    
    ```console
    $ gunicorn main:app --workers 4 --worker-class uvicorn.workers.UvicornWorker --bind 0.0.0.0:80
    
    [19499] [INFO] Starting gunicorn 20.1.0
    [19499] [INFO] Listening at: http://0.0.0.0:80 (19499)
    [19499] [INFO] Using worker: uvicorn.workers.UvicornWorker
    [19511] [INFO] Booting worker with pid: 19511
    [19513] [INFO] Booting worker with pid: 19513
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        return UnknownLengthSource()
      }
    
      /**
       * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout
       * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled
       * connections.
       */
      private fun detachTimeout(timeout: ForwardingTimeout) {
        val oldDelegate = timeout.delegate
        timeout.setDelegate(Timeout.NONE)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
Back to top