- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for SetLimit (0.36 sec)
-
src/cmd/vendor/golang.org/x/sync/errgroup/errgroup.go
} }() return true } // SetLimit limits the number of active goroutines in this group to at most n. // A negative value indicates no limit. // // Any subsequent call to the Go method will block until it can add an active // goroutine without exceeding the configured limit. // // The limit must not be modified while any goroutines in the group are active. func (g *Group) SetLimit(n int) { if n < 0 { g.sem = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:57:25 UTC 2024 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/visitor.go
// as it preserves the previous behavior, but allows components to opt into // concurrency. concurrency := 1 if l.concurrency > concurrency { concurrency = l.concurrency } g.SetLimit(concurrency) for i := range l.visitors { i := i g.Go(func() error { return l.visitors[i].Visit(fn) }) } return g.Wait() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 10:17:56 UTC 2023 - 21.3K bytes - Viewed (0) -
src/cmd/go/internal/base/limit.go
"runtime" "strconv" "sync" ) var NetLimitGodebug = godebug.New("#cmdgonetlimit") // NetLimit returns the limit on concurrent network operations // configured by GODEBUG=cmdgonetlimit, if any. // // A limit of 0 (indicated by 0, true) means that network operations should not // be allowed. func NetLimit() (int, bool) { netLimitOnce.Do(func() { s := NetLimitGodebug.Value() if s == "" { return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 19 02:47:12 UTC 2023 - 1.9K bytes - Viewed (0) -
src/cmd/go/go_test.go
// external network in parallel. If non-nil, it contains one buffer slot per // test (send to acquire), with a low enough limit that the overall number of // connections (summed across subprocesses) stays at or below base.NetLimit. var netTestSem chan struct{} var exeSuffix string = func() string { if runtime.GOOS == "windows" { return ".exe" } return "" }() func tooSlow(t *testing.T, reason string) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 81.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/transforms/legalize_tf.cc
if (result_type.hasStaticShape()) { return failure(); } Value start = op.getStart(); Value delta = op.getDelta(); Value limit = op.getLimit(); // To compute the length we need to use floating point calculations so that // ceil can be computed for the number of steps. auto compute_element_type =
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 20:00:43 UTC 2024 - 291.8K bytes - Viewed (0)