- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for dequeue1 (0.26 sec)
-
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 58.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
queueSkip queueingStrategy = iota // queueAfterBackoff indicates that the scheduling queue should requeue the Pod after backoff is completed. queueAfterBackoff // queueImmediately indicates that the scheduling queue should skip backoff and requeue the Pod immediately to activeQ. queueImmediately ) // isEventOfInterest returns true if the event is of interest by some plugins.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
watcher.stopLocked() } c.watchersToStop = c.watchersToStop[:0] for _, watcher := range c.expiredBookmarkWatchers { if watcher.stopped { continue } // requeue the watcher for the next bookmark if needed. c.bookmarkWatchers.addWatcherThreadUnsafe(watcher) } c.expiredBookmarkWatchers = c.expiredBookmarkWatchers[:0] } func (c *Cacher) terminateAllWatchers() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %+v: %v", obj, err)) return } jm.orphanQueue.Add(key) } // worker runs a worker thread that just dequeues items, processes them, and marks them done. // It enforces that the syncHandler is never invoked concurrently with the same key. func (jm *Controller) worker(ctx context.Context) { for jm.processNextWorkItem(ctx) { }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)