Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for gomaxprocs (0.12 sec)

  1. src/runtime/gc_test.go

    func applyGCLoad(b *testing.B) func() {
    	// We’ll apply load to the runtime with maxProcs-1 goroutines
    	// and use one more to actually benchmark. It doesn't make sense
    	// to try to run this test with only 1 P (that's what
    	// BenchmarkReadMemStats is for).
    	maxProcs := runtime.GOMAXPROCS(-1)
    	if maxProcs == 1 {
    		b.Skip("This benchmark can only be run with GOMAXPROCS > 1")
    	}
    
    	// Code to build a big tree with lots of pointers.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 05 22:33:52 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  2. src/runtime/metrics_test.go

    			fn: func(t *testing.T) {
    				runtime.GC()
    			},
    		},
    		{
    			name: "runtime.GOMAXPROCS",
    			fn: func(t *testing.T) {
    				if runtime.GOARCH == "wasm" {
    					t.Skip("GOMAXPROCS >1 not supported on wasm")
    				}
    
    				n := runtime.GOMAXPROCS(0)
    				defer runtime.GOMAXPROCS(n)
    
    				runtime.GOMAXPROCS(n + 1)
    			},
    		},
    		{
    			name: "runtime.GoroutineProfile",
    			fn: func(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:52:17 UTC 2024
    - 45K bytes
    - Viewed (0)
  3. internal/grid/benchmark_test.go

    	errFatal(err)
    
    	// Wait for all to connect
    	// Parallel writes per server.
    	b.Run("bytes", func(b *testing.B) {
    		for par := 1; par <= 32; par *= 2 {
    			b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
    				defer timeout(60 * time.Second)()
    				ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    				defer cancel()
    				b.ReportAllocs()
    				b.SetBytes(int64(len(payload) * 2))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. src/iter/pull_test.go

    	// the same 100 times in a row. This should be more than enough to
    	// ensure all goroutines get a chance to run to completion (or to
    	// some block point) for a small group of test goroutines.
    	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(1))
    
    	c := 0
    	ng := runtime.NumGoroutine()
    	for i := 0; i < 1000; i++ {
    		nng := runtime.NumGoroutine()
    		if nng == ng {
    			c++
    		} else {
    			c = 0
    			ng = nng
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:09:28 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. hack/lib/golang.sh

          export GOMAXPROCS
          kube::log::status "Set GOMAXPROCS automatically to ${GOMAXPROCS}"
        fi
      fi
    }
    
    # This will take binaries from $GOPATH/bin and copy them to the appropriate
    # place in ${KUBE_OUTPUT_BIN}
    #
    # Ideally this wouldn't be necessary and we could just set GOBIN to
    # KUBE_OUTPUT_BIN but that won't work in the face of cross compilation.  'go
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 16:43:08 UTC 2024
    - 32.8K bytes
    - Viewed (0)
  6. src/runtime/export_test.go

    	trigger, _ := c.trigger()
    	if c.heapMarked > trigger {
    		trigger = c.heapMarked
    	}
    	c.maxStackScan.Store(stackSize)
    	c.globalsScan.Store(globalsSize)
    	c.heapLive.Store(trigger)
    	c.heapScan.Add(int64(float64(trigger-c.heapMarked) * scannableFrac))
    	c.startCycle(0, gomaxprocs, gcTrigger{kind: gcTriggerHeap})
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:50:53 UTC 2024
    - 46.1K bytes
    - Viewed (0)
  7. src/sync/pool.go

    	l := p.local
    	if uintptr(pid) < s {
    		return indexLocal(l, pid), pid
    	}
    	if p.local == nil {
    		allPools = append(allPools, p)
    	}
    	// If GOMAXPROCS changes between GCs, we re-allocate the array and lose the old one.
    	size := runtime.GOMAXPROCS(0)
    	local := make([]poolLocal, size)
    	atomic.StorePointer(&p.local, unsafe.Pointer(&local[0])) // store-release
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 9.4K bytes
    - Viewed (1)
  8. manifests/charts/istio-control/istio-discovery/files/gateway-injection-template.yaml

                {{- end }}
              {{- end}}
            {{- end}}
            ]
        - name: GOMEMLIMIT
          valueFrom:
            resourceFieldRef:
              resource: limits.memory
        - name: GOMAXPROCS
          valueFrom:
            resourceFieldRef:
              resource: limits.cpu
        {{- if .CompliancePolicy }}
        - name: COMPLIANCE_POLICY
          value: "{{ .CompliancePolicy }}"
        {{- end }}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 01:55:05 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  9. src/runtime/extern.go

    See the documentation for those packages for details.
    
    The GOMAXPROCS variable limits the number of operating system threads that
    can execute user-level Go code simultaneously. There is no limit to the number of threads
    that can be blocked in system calls on behalf of Go code; those do not count against
    the GOMAXPROCS limit. This package's [GOMAXPROCS] function queries and changes
    the limit.
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:52:17 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  10. manifests/charts/istio-control/istio-discovery/templates/deployment.yaml

              - name: GOMEMLIMIT
                valueFrom:
                  resourceFieldRef:
                    resource: limits.memory
              - name: GOMAXPROCS
                valueFrom:
                  resourceFieldRef:
                    resource: limits.cpu
              - name: PLATFORM
                value: "{{ .Values.global.platform }}"
              resources:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 30 20:24:06 UTC 2024
    - 9K bytes
    - Viewed (0)
Back to top