- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for goroutines (0.16 sec)
-
src/runtime/mprof.go
// // Some goroutines (the finalizer goroutine, which at various times can be // either a "system" or a "user" goroutine, and the goroutine that is // coordinating the profile, any goroutines created during the profile) move // directly to the "Satisfied" state. type goroutineProfileState uint32 const ( goroutineProfileAbsent goroutineProfileState = iota goroutineProfileInProgress
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
src/runtime/pprof/pprof_test.go
for j := 0; j < i; j++ { // Spin for longer and longer as the test goes on. This // goroutine will do O(N^2) work with the number of // goroutines it launches. This should be slow relative to // the work involved in collecting a goroutine profile, // which is O(N) with the high-water mark of the number of // goroutines in this process (in the allgs slice). runtime.Gosched() } if i == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 68.8K bytes - Viewed (0) -
src/runtime/mgc.go
// N.B. we intentionally wait on each goroutine individually // rather than starting all in a batch and then waiting once // afterwards. By running one goroutine at a time, we can take // advantage of runnext to bounce back and forth between // workers and this goroutine. In an overloaded application, // this can reduce GC start latency by prioritizing these // goroutines rather than waiting on the end of the run queue.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K 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/time/time_test.go
// and that we also don't panic. func TestConcurrentTimerReset(t *testing.T) { const goroutines = 8 const tries = 1000 var wg sync.WaitGroup wg.Add(goroutines) timer := NewTimer(Hour) for i := 0; i < goroutines; i++ { go func(i int) { defer wg.Done() for j := 0; j < tries; j++ { timer.Reset(Hour + Duration(i*j)) } }(i)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:13:47 UTC 2024 - 56.5K bytes - Viewed (0) -
src/runtime/mgcmark.go
} // TODO: suspendG blocks (and spins) until gp // stops, which may take a while for // running goroutines. Consider doing this in // two phases where the first is non-blocking: // we scan the stacks we can and ask running // goroutines to scan themselves; and the // second blocks. stopped := suspendG(gp) if stopped.dead { gp.gcscandone = true return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
// Each request is sent from a separate goroutine, with a client-side timeout of 1m, on // the other hand, the server enforces a timeout of 5s (via the timeout filter). // The first request should get dispatched immediately; execution (a) starts with closing // the channel that triggers the second client goroutine to send its request and then (b) // waits for both client goroutines to have gotten a response (expected to be timeouts).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
src/internal/trace/order.go
return fmt.Errorf("expected no proc but had one") } // Check goroutine requirements. if reqs.Goroutine == event.MustHave && ctx.G == NoGoroutine { return fmt.Errorf("expected a goroutine but didn't have one") } else if reqs.Goroutine == event.MustNotHave && ctx.G != NoGoroutine { return fmt.Errorf("expected no goroutine but had one") } return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
src/runtime/mgcpacer.go
// last GC cycle. lastStackScan atomic.Uint64 // maxStackScan is the amount of allocated goroutine stack space in // use by goroutines. // // This number tracks allocated goroutine stack space rather than used // goroutine stack space (i.e. what is actually scanned) because used // goroutine stack space is much harder to measure cheaply. By using // allocated space, we make an overestimate; this is OK, it's better
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 55.4K bytes - Viewed (0) -
src/os/os_test.go
// Note the deferred Wait must be called after the deferred close(done), // to ensure the N goroutines have been released even if the main goroutine // calls Fatalf. It must be called before the Chdir back to the original // directory, and before the deferred deletion implied by TempDir, // so as not to interfere while the N goroutines are still running. defer wg.Wait() defer close(done) for i := 0; i < N; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 83.1K bytes - Viewed (0)