Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for SetLimit (0.36 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top