- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 75 for RunParallel (0.21 sec)
-
src/fmt/fmt_test.go
func BenchmarkSprintfPadding(b *testing.B) { b.RunParallel(func(pb *testing.PB) { for pb.Next() { _ = Sprintf("%16f", 1.0) } }) } func BenchmarkSprintfEmpty(b *testing.B) { b.RunParallel(func(pb *testing.PB) { for pb.Next() { _ = Sprintf("") } }) } func BenchmarkSprintfString(b *testing.B) { b.RunParallel(func(pb *testing.PB) { for pb.Next() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:31:55 UTC 2024 - 58.6K bytes - Viewed (0) -
src/internal/poll/splice_linux_test.go
} }) } func BenchmarkSplicePipePoolParallel(b *testing.B) { b.RunParallel(func(pb *testing.PB) { for pb.Next() { p, err := poll.GetPipe() if err != nil { continue } poll.PutPipe(p) } }) } func BenchmarkSplicePipeNativeParallel(b *testing.B) { b.RunParallel(func(pb *testing.PB) { for pb.Next() { p := poll.NewPipe() if p == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 2.8K bytes - Viewed (0) -
src/testing/benchmark.go
return false } } pb.cache-- return true } // RunParallel runs a benchmark in parallel. // It creates multiple goroutines and distributes b.N iterations among them. // The number of goroutines defaults to GOMAXPROCS. To increase parallelism for // non-CPU-bound benchmarks, call [B.SetParallelism] before RunParallel. // RunParallel is usually used with the go test -cpu flag. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/bench_test.go
structured, err := runtime.Decode(decoder, test.obj) if err != nil { b.Fatalf("Failed to parse yaml object: %v", err) } b.Run("structured", func(b *testing.B) { b.ReportAllocs() b.RunParallel(func(pb *testing.PB) { for pb.Next() { _, err := fakeTypeConverter.ObjectToTyped(structured) if err != nil { b.Errorf("Error in ObjectToTyped: %v", err) } } })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 8.9K bytes - Viewed (0) -
internal/grid/benchmark_test.go
defer cancel() b.ReportAllocs() b.SetBytes(int64(len(payload) * 2)) b.ResetTimer() t := time.Now() var ops int64 var lat int64 b.SetParallelism(par) b.RunParallel(func(pb *testing.PB) { rng := rand.New(rand.NewSource(time.Now().UnixNano())) n := 0 var latency int64 managers := grid.Managers hosts := grid.Hosts for pb.Next() {
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/sync/pool_test.go
p.Put("a") t.Error("should have panicked already") }) } func BenchmarkPool(b *testing.B) { var p Pool b.RunParallel(func(pb *testing.PB) { for pb.Next() { p.Put(1) p.Get() } }) } func BenchmarkPoolOverflow(b *testing.B) { var p Pool b.RunParallel(func(pb *testing.PB) { for pb.Next() { for b := 0; b < 100; b++ { p.Put(1) } for b := 0; b < 100; b++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8K bytes - Viewed (0) -
src/runtime/chan_test.go
close(x) }) }) } func BenchmarkChanNonblocking(b *testing.B) { myc := make(chan int) b.RunParallel(func(pb *testing.PB) { for pb.Next() { select { case <-myc: default: } } }) } func BenchmarkSelectUncontended(b *testing.B) { b.RunParallel(func(pb *testing.PB) { myc1 := make(chan int, 1) myc2 := make(chan int, 1) myc1 <- 0 for pb.Next() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 20:47:35 UTC 2023 - 23.4K bytes - Viewed (0) -
src/runtime/norace_test.go
benchmarkSyscall(b, 0, 4) } func BenchmarkSyscallExcessWork(b *testing.B) { benchmarkSyscall(b, 100, 4) } func benchmarkSyscall(b *testing.B, work, excess int) { b.SetParallelism(excess) b.RunParallel(func(pb *testing.PB) { foo := 42 for pb.Next() { runtime.Entersyscall() for i := 0; i < work; i++ { foo *= 2 foo /= 2 } runtime.Exitsyscall() } _ = foo })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 05 17:54:15 UTC 2022 - 983 bytes - Viewed (0) -
src/encoding/gob/timing_test.go
) type Bench struct { A int B float64 C string D []byte } func benchmarkEndToEnd(b *testing.B, ctor func() any, pipe func() (r io.Reader, w io.Writer, err error)) { b.ReportAllocs() b.RunParallel(func(pb *testing.PB) { r, w, err := pipe() if err != nil { b.Fatal("can't get pipe:", err) } v := ctor() enc := NewEncoder(w) dec := NewDecoder(r) for pb.Next() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 04 07:16:59 UTC 2023 - 6.5K bytes - Viewed (0) -
tests/integration/README.md
Run(func(ctx framework.TestContext) { ctx.NewSubTest("T1a"). RunParallel(func(ctx framework.TestContext) { // Run in parallel with T1b }) ctx.NewSubTest("T1b"). RunParallel(func(ctx framework.TestContext) { // Run in parallel with T1a })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 20.9K bytes - Viewed (0)