Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 348 for Gomaxprocs (0.3 sec)

  1. src/time/sleep_test.go

    	// the indicated delay.
    	//
    	// Even if GOMAXPROCS=1, we expect the runtime to eventually schedule
    	// the AfterFunc goroutine instead of the runnable channel goroutine.
    	// However, in https://go.dev/issue/65178 this was observed to live-lock
    	// on wasip1/wasm and js/wasm after <10000 runs.
    	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(1))
    
    	var (
    		wg   sync.WaitGroup
    		stop atomic.Bool
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 16:33:57 UTC 2024
    - 22.5K bytes
    - Viewed (0)
  2. src/runtime/testdata/testprogcgo/pprof_callback.go

    	// it possible for sysmon to retake Ps, forcing C calls to go down the
    	// desired exitsyscall path.
    	//
    	// High GOMAXPROCS is used to increase opportunities for failure on
    	// high CPU machines.
    	const (
    		P = 16
    		G = 64
    	)
    	runtime.GOMAXPROCS(P)
    
    	f, err := os.CreateTemp("", "prof")
    	if err != nil {
    		fmt.Fprintln(os.Stderr, err)
    		os.Exit(2)
    	}
    	defer f.Close()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 08 15:44:05 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  3. hack/tools/ncpu/main.go

    limitations under the License.
    */
    
    package main
    
    import (
    	"fmt"
    	"runtime"
    
    	"go.uber.org/automaxprocs/maxprocs"
    )
    
    func main() {
    	maxprocs.Set()
    	fmt.Print(runtime.GOMAXPROCS(0))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 31 00:26:07 UTC 2023
    - 719 bytes
    - Viewed (0)
  4. src/cmd/go/testdata/script/build_concurrent_backend.txt

    # Tests golang.org/issue/48490
    # cmd/go should enable concurrent compilation by default
    
    # Reset all experiments, since one of them can disable
    # concurrent compilation, e.g: fieldtrack.
    env GOEXPERIMENT=none
    
    env GOMAXPROCS=4
    go build -n -x -a fmt
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 05 01:30:56 UTC 2021
    - 265 bytes
    - Viewed (0)
  5. 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)
  6. internal/s3select/json/preader.go

    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *PReader) startReaders() {
    	r.bufferPool.New = func() interface{} {
    		return make([]byte, jsonSplitSize+1024)
    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  7. cmd/speedtest.go

    			// operations for now to begin with.
    			if concurrency < 4 {
    				concurrency = 4
    			}
    
    			// if GOMAXPROCS is set to a lower value then choose to use
    			// concurrency == GOMAXPROCS instead.
    			if runtime.GOMAXPROCS(0) < concurrency {
    				concurrency = runtime.GOMAXPROCS(0)
    			}
    		}
    
    		throughputHighestGet := uint64(0)
    		throughputHighestPut := uint64(0)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. src/encoding/gob/timing_test.go

    		var buf bytes.Buffer
    		return &buf, &buf, nil
    	})
    }
    
    func TestCountEncodeMallocs(t *testing.T) {
    	if testing.Short() {
    		t.Skip("skipping malloc count in short mode")
    	}
    	if runtime.GOMAXPROCS(0) > 1 {
    		t.Skip("skipping; GOMAXPROCS>1")
    	}
    
    	const N = 1000
    
    	var buf bytes.Buffer
    	enc := NewEncoder(&buf)
    	bench := &Bench{7, 3.2, "now is the time", []byte("for all good men")}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 04 07:16:59 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  9. src/cmd/cgo/internal/test/issue18146.go

    				attempts = max
    			}
    		}
    	}
    
    	if os.Getenv("test18146") == "exec" {
    		runtime.GOMAXPROCS(1)
    		for n := threads; n > 0; n-- {
    			go func() {
    				for {
    					_ = md5.Sum([]byte("Hello, !"))
    				}
    			}()
    		}
    		runtime.GOMAXPROCS(threads)
    		argv := append(os.Args, "-test.run=^$")
    		if err := syscall.Exec(os.Args[0], argv, os.Environ()); err != nil {
    			t.Fatal(err)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 05 23:35:32 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  10. 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)
Back to top