- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 348 for gomaxprocs (0.16 sec)
-
src/runtime/testdata/testprog/crashdump.go
package main import ( "fmt" "os" "runtime" ) func init() { register("CrashDumpsAllThreads", CrashDumpsAllThreads) } func CrashDumpsAllThreads() { const count = 4 runtime.GOMAXPROCS(count + 1) chans := make([]chan bool, count) for i := range chans { chans[i] = make(chan bool) go crashDumpsAllThreadsLoop(i, chans[i]) } // Wait for all the goroutines to start executing.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 22 00:34:25 UTC 2021 - 917 bytes - Viewed (0) -
src/testing/benchmark.go
return true } // Collect matching benchmarks and determine longest name. maxprocs := 1 for _, procs := range cpuList { if procs > maxprocs { maxprocs = procs } } ctx := &benchContext{ match: newMatcher(matchString, *matchBenchmarks, "-test.bench", *skip), extLen: len(benchmarkName("", maxprocs)), } var bs []InternalBenchmark for _, Benchmark := range benchmarks {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23.9K 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(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) -
src/strconv/strconv_test.go
func TestCountMallocs(t *testing.T) { if testing.Short() { t.Skip("skipping malloc count in short mode") } if runtime.GOMAXPROCS(0) > 1 { t.Skip("skipping; GOMAXPROCS>1") } // Allocate a big messy buffer for AppendQuoteToASCII's test. oneMB = make([]byte, 1e6) for i := range oneMB { oneMB[i] = byte(i) } for _, mt := range mallocTest {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 23 20:29:22 UTC 2022 - 4.7K bytes - Viewed (0) -
test/fixedbugs/issue25897b.go
package main import ( "reflect" "runtime" ) const N = 100 type T struct { } func (t *T) Foo(c chan bool) { c <- true } func main() { t := &T{} runtime.GOMAXPROCS(1) c := make(chan bool, N) for i := 0; i < N; i++ { f := reflect.ValueOf(t).MethodByName("Foo").Interface().(func(chan bool)) go f(c) } runtime.GC() for i := 0; i < N; i++ { <-c }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 18:50:30 UTC 2019 - 651 bytes - Viewed (0) -
src/cmd/go/testdata/script/test_fuzz_fuzztime.txt
go test # For the fuzzing phase, we reduce GOMAXPROCS to avoid consuming too many # resources during the test. Ideally this would just free up resources to run # other parallel tests more quickly, but unfortunately it is actually necessary # in some 32-bit environments to prevent the fuzzing engine from running out of # address space (see https://go.dev/issue/65434). env GOMAXPROCS=2
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 01 20:09:52 UTC 2024 - 3.1K bytes - Viewed (0) -
src/os/timeout_test.go
// Cannot use t.Parallel - modifies global GOMAXPROCS. if testing.Short() { t.Skip("skipping in short mode") } defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(1)) testVariousDeadlines(t) } // There is a very similar copy of this in net/timeout_test.go. func TestVariousDeadlines4Proc(t *testing.T) { // Cannot use t.Parallel - modifies global GOMAXPROCS. if testing.Short() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 17.1K bytes - Viewed (0) -
src/path/path_test.go
} } } func TestCleanMallocs(t *testing.T) { if testing.Short() { t.Skip("skipping malloc count in short mode") } if runtime.GOMAXPROCS(0) > 1 { t.Log("skipping AllocsPerRun checks; GOMAXPROCS>1") return } for _, test := range cleantests { allocs := testing.AllocsPerRun(100, func() { Clean(test.result) }) if allocs > 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 13 01:12:09 UTC 2020 - 4.6K bytes - Viewed (0) -
pilot/pkg/features/tuning.go
"If set to 0 or unset, the max will be automatically determined based on the machine size", ).Get() if v > 0 { return v } procs := runtime.GOMAXPROCS(0) // Heuristic to scale with cores. We end up with... // 1: 20 // 2: 25 // 4: 35 // 32: 100 return min(15+5*procs, 100) }() RequestLimit = func() float64 { v := env.Register(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 04:22:19 UTC 2024 - 4.8K bytes - Viewed (1) -
test/fixedbugs/issue11256.go
// returning. package main import ( "runtime" "sync/atomic" "time" ) func main() { // Let the garbage collector run concurrently. runtime.GOMAXPROCS(2) var x [100][]byte for i := range x { var done int32 go func() { // Use enough stack to get stack barriers, but // not so much that we go over _FixedStack.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 29 15:02:30 UTC 2015 - 1.1K bytes - Viewed (0)