- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 111 for wakep (0.24 sec)
-
android/guava/src/com/google/common/util/concurrent/Monitor.java
* called when waits are interrupted. * * <p>On the other hand, if a signalled thread wakes up to discover that its guard is still not * satisfied, it does *not* need to call this method before returning to wait. This can only * happen due to spurious wakeup (ignorable) or another thread acquiring the lock before the
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0) -
src/runtime/mgc.go
// there was neither enough credit to steal or enough work to // do. assistQueue struct { lock mutex q gQueue } // sweepWaiters is a list of blocked goroutines to wake when // we transition from mark termination to sweep. sweepWaiters struct { lock mutex list gList } // cycles is the number of completed GC cycles, where a GC
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
src/internal/trace/traceviewer/http.go
Garbage collection may temporarily affect all the logical processors and the other metrics. The "Network", "Timers", and "Syscalls" traces indicate events in the runtime that cause goroutines to wake up. </p> <p> The visualization allows you to navigate events at scales ranging from several seconds to a handful of nanoseconds.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:29:53 UTC 2023 - 12.6K bytes - Viewed (0) -
src/runtime/mgcwork.go
w.wbuf2 = getempty() } else if wbuf := w.wbuf1; wbuf.nobj > 4 { w.wbuf1 = handoff(wbuf) w.flushedWork = true // handoff did putfull } else { return } // We flushed a buffer to the full list, so wake a worker. if gcphase == _GCmark { gcController.enlistWorker() } } // empty reports whether w has no mark work available. // //go:nowritebarrierrec func (w *gcWork) empty() bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 12.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
* called when waits are interrupted. * * <p>On the other hand, if a signalled thread wakes up to discover that its guard is still not * satisfied, it does *not* need to call this method before returning to wait. This can only * happen due to spurious wakeup (ignorable) or another thread acquiring the lock before the
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/loop_test.go
intervalMin := func(backoff Backoff) time.Duration { d := backoff.Duration return d } // Because timing is dependent other factors in test environments, such as // whether the OS or go runtime scheduler wake the timers, excess duration // is logged by default and can be converted to a fatal error for testing. // fail := t.Fatalf fail := t.Logf for _, test := range []struct { name string backoff Backoff
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 02:48:08 UTC 2023 - 15.8K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
} logger.V(4).Info("Orphan Pod created", "pod", klog.KObj(pod), "detail", pod) for _, rs := range rss { rsc.enqueueRS(rs) } } // When a pod is updated, figure out what replica set/s manage it and wake them // up. If the labels of the pod have changed we need to awaken both the old // and new replica set. old and cur must be *v1.Pod types. func (rsc *ReplicaSetController) updatePod(logger klog.Logger, old, cur interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
// block's timestamp to see if it should evict any files. At the current fake // timestamp of `now` + 2, file "a" is stale because its first block is stale, // but file "b" is not stale yet. Thus, once the pruning thread wakes up (in // one second of wall time), it should remove "a" and leave "b" alone. uint64 start = Env::Default()->NowSeconds(); do { Env::Default()->SleepForMicroseconds(100000);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Oct 15 03:16:57 UTC 2021 - 23.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver.go
} // Return the last fetch directly, reaching here means we have tried `retry` times, this will be // the last time for the retry. return getPublicKey() } func (r *JwksResolver) refresher() { // Wake up once in a while and refresh stale items. r.refreshTicker = time.NewTicker(r.refreshInterval) lastHasError := false for { select { case <-r.refreshTicker.C: if !r.jwksUribackgroundChannel {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 20.3K bytes - Viewed (0)