Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for GOMAXPROCS (0.07 sec)

  1. internal/lsync/lrwmutex_test.go

    		clocked <- true
    		<-cunlock
    		m.RUnlock()
    		cdone <- true
    	}
    }
    
    // Borrowed from rwmutex_test.go
    func doTestParallelReaders(numReaders, gomaxprocs int) {
    	runtime.GOMAXPROCS(gomaxprocs)
    	m := NewLRWMutex()
    
    	clocked := make(chan bool)
    	cunlock := make(chan bool)
    	cdone := make(chan bool)
    	for i := 0; i < numReaders; i++ {
    Registered: 2025-05-25 19:28
    - Last Modified: 2025-04-09 14:28
    - 7.8K bytes
    - Viewed (0)
  2. doc/next/6-stdlib/99-minor/runtime/73193.md

    The new [SetDefaultGOMAXPROCS] function sets `GOMAXPROCS` to the runtime
    default value, as if the `GOMAXPROCS` environment variable is not set. This is
    useful for enabling the [new `GOMAXPROCS` default](#runtime) if it has been
    disabled by the `GOMAXPROCS` environment variable or a prior call to
    Registered: 2025-05-27 11:13
    - Last Modified: 2025-05-21 17:21
    - 311 bytes
    - Viewed (0)
  3. doc/next/4-runtime.md

    Both of these behaviors are automatically disabled if `GOMAXPROCS` is set
    manually via the `GOMAXPROCS` environment variable or a call to
    [runtime.GOMAXPROCS]. They can also be disabled explicitly with the [GODEBUG
    settings](/doc/godebug) `containermaxprocs=0` and `updatemaxprocs=0`,
    respectively.
    
    In order to support reading updated cgroup limits, the runtime will keep cached
    file descriptors for the cgroup files for the duration of the process lifetime.
    Registered: 2025-05-27 11:13
    - Last Modified: 2025-05-21 17:21
    - 2.6K bytes
    - Viewed (0)
  4. internal/dsync/drwmutex_test.go

    		}
    	}
    	cdone <- true
    }
    
    // Borrowed from rwmutex_test.go
    func hammerRWMutex(t *testing.T, gomaxprocs, numReaders, numIterations int) {
    	t.Run(fmt.Sprintf("%d-%d-%d", gomaxprocs, numReaders, numIterations), func(t *testing.T) {
    		resource := "test"
    		runtime.GOMAXPROCS(gomaxprocs)
    		// Number of active readers + 10000 * number of active writers.
    		var activity int32
    		cdone := make(chan bool)
    Registered: 2025-05-25 19:28
    - Last Modified: 2025-04-09 14:28
    - 9.5K bytes
    - Viewed (0)
  5. internal/s3select/progress.go

    	"github.com/pierrec/lz4/v4"
    )
    
    type countUpReader struct {
    	reader    io.Reader
    	bytesRead int64
    }
    
    // Max bzip2 concurrency across calls. 50% of GOMAXPROCS.
    var bz2Limiter = pbzip2.CreateConcurrencyPool((runtime.GOMAXPROCS(0) + 1) / 2)
    
    func (r *countUpReader) Read(p []byte) (n int, err error) {
    	n, err = r.reader.Read(p)
    	atomic.AddInt64(&r.bytesRead, int64(n))
    	return n, err
    }
    
    Registered: 2025-05-25 19:28
    - Last Modified: 2024-09-22 00:33
    - 4.3K 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() []byte {
    		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: 2025-05-25 19:28
    - Last Modified: 2025-02-18 16:25
    - 6.5K bytes
    - Viewed (0)
  7. internal/s3select/csv/reader.go

    	// Check if first block is valid.
    	if !utf8.Valid(next) {
    		return errInvalidTextEncodingError()
    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    	// Start splitter
    	go func() {
    		defer close(r.input)
    		defer close(r.queue)
    		defer r.readerWg.Done()
    		for {
    			q := queueItem{
    Registered: 2025-05-25 19:28
    - Last Modified: 2025-02-18 16:25
    - 8.8K bytes
    - Viewed (0)
  8. 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: 2025-05-25 19:28
    - Last Modified: 2024-05-06 09:45
    - 9.2K bytes
    - Viewed (0)
  9. 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(b.Context(), 30*time.Second)
    				defer cancel()
    				b.ReportAllocs()
    				b.SetBytes(int64(len(payload) * 2))
    Registered: 2025-05-25 19:28
    - Last Modified: 2025-04-09 14:28
    - 15.6K bytes
    - Viewed (0)
  10. cmd/admin-server-info.go

    			Alloc:      memstats.Alloc,
    			TotalAlloc: memstats.TotalAlloc,
    			Mallocs:    memstats.Mallocs,
    			Frees:      memstats.Frees,
    			HeapAlloc:  memstats.HeapAlloc,
    		},
    		GoMaxProcs:     runtime.GOMAXPROCS(0),
    		NumCPU:         runtime.NumCPU(),
    		RuntimeVersion: runtime.Version(),
    		GCStats: &madmin.GCStats{
    			LastGC:     gcStats.LastGC,
    			NumGC:      gcStats.NumGC,
    			PauseTotal: gcStats.PauseTotal,
    Registered: 2025-05-25 19:28
    - Last Modified: 2024-05-24 23:05
    - 4.9K bytes
    - Viewed (1)
Back to top