- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for GOMAXPROCS (0.07 sec)
-
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) -
doc/next/6-stdlib/99-minor/runtime/73193.md
Registered: 2025-05-27 11:13 - Last Modified: 2025-05-21 17:21 - 311 bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)