- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 935 for goroutines (0.61 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/counter/interface.go
type GoRoutineCounter interface { // Add adds the given delta to the count of active goroutines. // Call Add(1) before forking a goroutine, Add(-1) at the end of that goroutine. // Call Add(-1) just before waiting on something from another goroutine (e.g., // just before a `select`). // Call Add(1) just before doing something that unblocks a goroutine that is // waiting on that something. Add(delta int)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 12 16:12:48 UTC 2019 - 1.4K bytes - Viewed (0) -
src/sync/mutex.go
} } // Unlock unlocks m. // It is a run-time error if m is not locked on entry to Unlock. // // A locked [Mutex] is not associated with a particular goroutine. // It is allowed for one goroutine to lock a Mutex and then // arrange for another goroutine to unlock it. func (m *Mutex) Unlock() { if race.Enabled { _ = m.state race.Release(unsafe.Pointer(m)) } // Fast path: drop lock bit.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
src/internal/trace/summary.go
CreationTime Time // Timestamp of the first appearance in the trace. StartTime Time // Timestamp of the first time it started running. 0 if the goroutine never ran. EndTime Time // Timestamp of when the goroutine exited. 0 if the goroutine never exited. // List of regions in the goroutine, sorted based on the start time. Regions []*UserRegionSummary // Statistics of execution time during the goroutine execution.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 20.7K bytes - Viewed (0) -
src/runtime/trace/trace.go
// additional information such as the category of the message and // which goroutine called [Log]. The execution tracer provides UIs to filter // and group goroutines using the log category and the message supplied // in [Log]. // // A region is for logging a time interval during a goroutine's execution. // By definition, a region starts and ends in the same goroutine. // Regions can be nested to represent subintervals.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 20 00:47:09 UTC 2023 - 5.1K bytes - Viewed (0) -
src/sync/waitgroup.go
"internal/race" "sync/atomic" "unsafe" ) // A WaitGroup waits for a collection of goroutines to finish. // The main goroutine calls [WaitGroup.Add] to set the number of // goroutines to wait for. Then each of the goroutines // runs and calls [WaitGroup.Done] when finished. At the same time, // [WaitGroup.Wait] can be used to block until all goroutines have finished. // // A WaitGroup must not be copied after first use. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
pkg/ctrlz/topics/assets/templates/proc.html
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.2K bytes - Viewed (0) -
src/net/http/main_test.go
// goroutines are a new leak from a subsequent test or just the same // goroutines from the first leak still hanging around, and we may add a lot // of latency waiting for them to exit at the end of each test. return } // We shouldn't be running the leak check for parallel tests, because we might // report the goroutines from a test that is still running as a leak from a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 22:49:46 UTC 2024 - 4.9K bytes - Viewed (0) -
src/runtime/race/timer_test.go
//go:build race package race_test import ( "sync" "testing" "time" ) func TestTimers(t *testing.T) { const goroutines = 8 var wg sync.WaitGroup wg.Add(goroutines) var mu sync.Mutex for i := 0; i < goroutines; i++ { go func() { defer wg.Done() ticker := time.NewTicker(1) defer ticker.Stop() for c := 0; c < 1000; c++ { <-ticker.C mu.Lock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 576 bytes - Viewed (0) -
cmd/leak-detect_test.go
for _, g := range leaked { t.Errorf("Leaked goroutine: %v", g) } return } } // DetectTestLeak - snapshots the currently running goroutines and returns a // function to be run at the end of tests to see whether any // goroutines leaked. // Usage: `defer DetectTestLeak(t)()` in beginning line of benchmarks or unit tests.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.2K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress-start-stop.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Tests a many interesting cases (network, syscalls, a little GC, busy goroutines, // blocked goroutines, LockOSThread, pipes, and GOMAXPROCS). //go:build ignore package main import ( "bytes" "io" "log" "net" "os" "runtime" "runtime/trace" "sync" "time" )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.7K bytes - Viewed (0)