Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 966 for concurrency (0.12 sec)

  1. cmd/peer-rest-server.go

    	result, err := selfSpeedTest(r.Context(), speedTestOpts{
    		objectSize:      size,
    		concurrency:     concurrent,
    		duration:        duration,
    		storageClass:    storageClass,
    		bucketName:      bucketName,
    		enableSha256:    enableSha256,
    		enableMultipart: enableMultipart,
    		creds:           u.Credentials,
    	})
    	if err != nil {
    		result.Error = err.Error()
    	}
    
    	done(nil)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  2. cmd/notification.go

    		}
    		results[len(results)-1] = r
    		results[len(results)-1].Endpoint = u.String()
    	}()
    	wg.Wait()
    
    	return results
    }
    
    // SpeedTest run GET/PUT tests at input concurrency for requested object size,
    // optionally you can extend the tests longer with time.Duration.
    func (sys *NotificationSys) SpeedTest(ctx context.Context, sopts speedTestOpts) []SpeedTestResult {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

            if (localRepositoryPath != null) {
                request.setLocalRepositoryPath(localRepositoryPath);
            }
    
            //
            // Builder, concurrency and parallelism
            //
            // We preserve the existing methods for builder selection which is to look for various inputs in the threading
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 76.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/cache/LocalCache.java

    import java.util.Queue;
    import java.util.Set;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReferenceArray;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.function.BiFunction;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.28.md

    - In the API Priority and Fairness feature, priority levels that are exempt from limitation can now be given a nominal and a lendable concurrency and their dispatching borrows from the concurrency limits of the other priority levels.  For details see https://github.com/kubernetes/enhancements/tree/master/keps/sig-api-machinery/1040-priority-and-fairness#dispatching . ([#118782](https://github.com/kubernetes/kube...
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 04:34:59 UTC 2024
    - 456.9K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.26.md

        - `apiserver_flowcontrol_current_limit_seats`: current derived number of execution seats available to each priority level
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Mar 14 16:24:51 UTC 2024
    - 425.7K bytes
    - Viewed (0)
  7. docs/ja/docs/async.md

    # 並行処理と async / await
    
    *path operation 関数*のための `async def` に関する詳細と非同期 (asynchronous) コード、並行処理 (Concurrency)、そして、並列処理 (Parallelism) の背景について。
    
    ## 急いでいますか?
    
    <abbr title="too long; didn't read (長すぎて読めない人のための要約という意味のスラング)"><strong>TL;DR:</strong></abbr>
    
    次のような、`await` を使用して呼び出すべきサードパーティライブラリを使用している場合:
    
    ```Python
    results = await some_library()
    ```
    
    以下の様に `async def` を使用して*path operation 関数*を宣言します。
    
    ```Python hl_lines="2"
    @app.get('/')
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    	globalInternodeTransport = NewInternodeHTTPTransport(0)()
    
    	initHelp()
    
    	resetTestGlobals()
    
    	globalIsCICD = true
    
    	os.Exit(m.Run())
    }
    
    // concurrency level for certain parallel tests.
    const testConcurrencyLevel = 10
    
    const iso8601TimeFormat = "2006-01-02T15:04:05.000Z"
    
    // Excerpts from @lsegal - https://github.com/aws/aws-sdk-js/issues/659#issuecomment-120477258
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  9. docs/en/docs/img/async/concurrent-burgers/concurrent-burgers-03.png

    concurrent-burgers-03.png...
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 17 10:48:05 UTC 2022
    - 168.9K bytes
    - Viewed (0)
  10. docs/en/docs/img/async/concurrent-burgers/concurrent-burgers-05.png

    concurrent-burgers-05.png...
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 17 10:48:05 UTC 2022
    - 156.1K bytes
    - Viewed (0)
Back to top