- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 662 for goroutines (0.17 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/request/webhook_duration.go
// it is safe for concurrent use by multiple goroutines. type DurationTracker interface { // Track measures time spent in the given function f and // aggregates measured duration using aggregateFunction. // if Track is invoked with f from multiple goroutines concurrently, // then f must be safe to be invoked concurrently by multiple goroutines. Track(f func())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 22:15:37 UTC 2024 - 11.5K bytes - Viewed (0) -
src/runtime/netpoll_solaris.go
// ourselves. After we receive an event for a file descriptor, // it's our responsibility to ask again to be notified for future // events for that descriptor. When doing this we must keep track of // what kind of events the goroutines are currently interested in, // for example a fd may be open both for reading and writing. // // A description of the high level operation of this code // follows. Networking code will get a file descriptor by some means
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0) -
src/runtime/race/testdata/rangefunc_test.go
) type Seq2[T1, T2 any] func(yield func(T1, T2) bool) // ofSliceIndex returns a Seq over the elements of s. It is equivalent // to range s, except that it splits s into two halves and iterates // in two separate goroutines. This is racy if yield is racy, and yield // will be racy if it contains an early exit. func ofSliceIndex[T any, S ~[]T](s S) Seq2[int, T] { return func(yield func(int, T) bool) { c := make(chan bool, 2)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 21:08:03 UTC 2024 - 1.8K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/cpu-profile.go
} // Examine the CPU profiler's view. Filter it to only include samples from // the single test goroutine. Use labels to execute that filter: they should // apply to all work done while that goroutine is getg().m.curg, and they // should apply to no other goroutines. pprofStacks := make(map[string]int) for _, s := range prof.Sample { if s.Label["tracing"] != nil { var fns []string
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 3.8K bytes - Viewed (0) -
src/database/sql/doc.txt
and shouldn't have to maintain their own free pools of connections. The 'sql' package should deal with that bookkeeping as needed. Given an *sql.DB, it should be possible to share that instance between multiple goroutines, without any extra synchronization. * Push complexity, where necessary, down into the sql+driver packages, rather than exposing it to users. Said otherwise, the sql package
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 06:48:08 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/queue/delay.go
return func(queue *delayQueue) { if queue.enqueue != nil { close(queue.enqueue) } queue.enqueue = make(chan *delayTask, bufferSize) } } // DelayQueueWorkers sets the number of background worker goroutines await tasks to execute. Effectively the // maximum number of concurrent tasks. func DelayQueueWorkers(workers int) DelayQueueOption { return func(queue *delayQueue) { queue.workers = workers } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K 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/main_test.go
gss := runningGoroutines() if len(gss) == 0 { return } fmt.Fprintf(os.Stderr, "Running goroutines:\n") for _, gs := range gss { fmt.Fprintf(os.Stderr, "%v\n", gs) } fmt.Fprintf(os.Stderr, "\n") } // runningGoroutines returns a list of remaining goroutines. func runningGoroutines() []string { var gss []string b := make([]byte, 2<<20) b = b[:runtime.Stack(b, true)]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 7.5K bytes - Viewed (0) -
src/runtime/chan_test.go
c[3] = make(chan int, 3) N := int(1e5) if testing.Short() { N /= 10 } // There are 4 goroutines that send N values on each of the chans, // + 4 goroutines that receive N values on each of the chans, // + 1 goroutine that sends N values on each of the chans in a single select, // + 1 goroutine that receives N values on each of the chans in a single select.
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/internal/trace/oldtrace.go
// all goroutines that already existed at trace begin. it.preInit = false for gid := range it.createdPreInit { // These are goroutines that already existed when tracing started but for which we // received neither GoWaiting, GoInSyscall, or GoStart. These are goroutines that are in // the states _Gidle or _Grunnable. it.extra = append(it.extra, Event{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0)