- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 805 for goroutineID (0.33 sec)
-
src/testing/benchmark_test.go
// RunParallel will create GOMAXPROCS goroutines // and distribute work among them. b.RunParallel(func(pb *testing.PB) { // Each goroutine has its own bytes.Buffer. var buf bytes.Buffer for pb.Next() { // The loop body is executed b.N times total across all goroutines. buf.Reset() templ.Execute(&buf, "World") } }) }) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 5.6K bytes - Viewed (0) -
src/runtime/crash_test.go
} } func TestNoHelperGoroutines(t *testing.T) { output := runTestProg(t, "testprog", "NoHelperGoroutines") matches := regexp.MustCompile(`goroutine [0-9]+ \[`).FindAllStringSubmatch(output, -1) if len(matches) != 1 || matches[0][0] != "goroutine 1 [" { t.Fatalf("want to see only goroutine 1, see:\n%s", output) } } func TestBreakpoint(t *testing.T) { output := runTestProg(t, "testprog", "Breakpoint")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 19:46:10 UTC 2024 - 27K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait.go
var NeverStop <-chan struct{} = make(chan struct{}) // Group allows to start a group of goroutines and wait for their completion. type Group struct { wg sync.WaitGroup } func (g *Group) Wait() { g.wg.Wait() } // StartWithChannel starts f in a new goroutine in the group. // stopCh is passed to f as an argument. f should stop when stopCh is available.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 7.1K bytes - Viewed (0) -
src/testing/testing.go
// by calling runtime.Goexit (which then runs all deferred calls in the // current goroutine). // Execution will continue at the next test or benchmark. // FailNow must be called from the goroutine running the // test or benchmark function, not from other goroutines // created during the test. Calling FailNow does not stop // those other goroutines. func (c *common) FailNow() { c.checkFuzzFn("FailNow") c.Fail()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 76.1K bytes - Viewed (0) -
src/net/timeout_test.go
c[i], err = Dial(ln.Addr().Network(), ln.Addr().String()) if err != nil { t.Fatal(err) } defer c[i].Close() } var wg sync.WaitGroup wg.Add(goroutines) now := time.Now() for i := 0; i < goroutines; i++ { go func(i int) { defer wg.Done() // Make the deadlines steadily earlier, // to trigger runtime adjusttimers calls. for j := tries; j > 0; j-- {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 18:06:55 UTC 2024 - 30K bytes - Viewed (0) -
src/net/http/pprof/pprof.go
"cmdline": "The command line invocation of the current program", "goroutine": "Stack traces of all current goroutines. Use debug=2 as a query parameter to export in the same format as an unrecovered panic.", "heap": "A sampling of memory allocations of live objects. You can specify the gc GET parameter to run GC before taking the heap sample.",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 17:34:05 UTC 2024 - 14.1K bytes - Viewed (0) -
src/net/http/httputil/dump_test.go
continue } } } // Validate we haven't leaked any goroutines. var dg int dl := deadline(t, 5*time.Second, time.Second) for time.Now().Before(dl) { if dg = runtime.NumGoroutine() - numg0; dg <= 4 { // No unexpected goroutines. return } // Allow goroutines to schedule and die off. runtime.Gosched() } buf := make([]byte, 4096)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 17:34:07 UTC 2022 - 12.5K bytes - Viewed (0) -
src/time/sleep.go
// delta is how long ago the channel send was supposed to happen. // The current time can be arbitrarily far into the future, because the runtime // can delay a sendTime call until a goroutines tries to receive from // the channel. Subtract delta to go back to the old time that we // used to send. select { case c.(chan Time) <- Now().Add(Duration(-delta)): default: } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 8.5K bytes - Viewed (0) -
src/time/sleep_test.go
<-ticker.C } }() } wg.Wait() ticker.Stop() stop.Store(true) } func TestAfterFuncStarvation(t *testing.T) { // Start two goroutines ping-ponging on a channel send. // At any given time, at least one of these goroutines is runnable: // if the channel buffer is full, the receiver is runnable, // and if it is not full, the sender is runnable. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 16:33:57 UTC 2024 - 22.5K bytes - Viewed (0) -
src/runtime/mbarrier.go
bulkBarrierPreWrite(uintptr(dst), uintptr(src), typ.PtrBytes, typ) } // There's a race here: if some other goroutine can write to // src, it may change some pointer in src after we've // performed the write barrier but before we perform the // memory copy. This safe because the write performed by that // other goroutine must also be accompanied by a write // barrier, so at worst we've unnecessarily greyed the old
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 15.7K bytes - Viewed (0)