- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 132 for queueset (0.6 sec)
-
guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* conventional bounded queues, which either block or reject new elements when full. * * <p>This implementation is based on the <a * href="http://portal.acm.org/citation.cfm?id=6621">min-max heap</a> developed by Atkinson, et al. * Unlike many other double-ended priority queues, it stores elements in a single array, as compact
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 34K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.cc
} // Wait for up to 'wait_for' milliseconds. if (wait_for > 0) { if (!counter_->WaitFor(std::chrono::milliseconds(wait_for))) { return Status(absl::StatusCode::kDeadlineExceeded, "Queues not fed before the timeout"); } // Check the status of the queue runner as well as the result of the enqueue // operations. mutex_lock l(mu_); if (!enqueue_status_.ok()) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
pkg/scheduler/apis/config/v1/zz_generated.conversion.go
if err := Convert_v1_PluginSet_To_config_PluginSet(&in.PreEnqueue, &out.PreEnqueue, s); err != nil { return err } if err := Convert_v1_PluginSet_To_config_PluginSet(&in.QueueSort, &out.QueueSort, s); err != nil { return err } if err := Convert_v1_PluginSet_To_config_PluginSet(&in.PreFilter, &out.PreFilter, s); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 18:47:23 UTC 2024 - 46.9K bytes - Viewed (0) -
src/runtime/tracebuf.go
w.varint(uint64(ts)) w.traceBuf.lenPos = w.varintReserve() return w } // traceBufQueue is a FIFO of traceBufs. type traceBufQueue struct { head, tail *traceBuf } // push queues buf into queue of buffers. func (q *traceBufQueue) push(buf *traceBuf) { buf.link = nil if q.head == nil { q.head = buf } else { q.tail.link = buf } q.tail = buf }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 6.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* conventional bounded queues, which either block or reject new elements when full. * * <p>This implementation is based on the <a * href="http://portal.acm.org/citation.cfm?id=6621">min-max heap</a> developed by Atkinson, et al. * Unlike many other double-ended priority queues, it stores elements in a single array, as compact
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 34K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DefaultDaemonConnectionTest.groovy
received.await() daemonConnection.stop() then: 1 * handler.run() >> { received.countDown(); throw new RuntimeException() } 0 * handler._ } def "receive queues incoming messages"() { when: connection.queueIncoming("incoming1") connection.queueIncoming("incoming2") connection.queueIncoming("incoming3") def result = []
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
limitations under the License. */ // This file contains structures that implement scheduling queue types. // Scheduling queues hold pods waiting to be scheduled. This file implements a // priority queue which has two sub queues and a additional data structure, // namely: activeQ, backoffQ and unschedulablePods. // - activeQ holds pods that are being considered for scheduling.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 finished run in 0 µs: task one", ) } /** * The runner doesn't hold references to its queues! Otherwise we'd need a mechanism to clean them * up when they're no longer needed and that's annoying. Instead the task runner only tracks which * queues have work scheduled. */ @Test fun activeQueuesContainsOnlyQueuesWithScheduledTasks() { redQueue.execute("task one", 100.µs) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
pkg/scheduler/metrics/metrics.go
SchedulerQueueIncomingPods = metrics.NewCounterVec( &metrics.CounterOpts{ Subsystem: SchedulerSubsystem, Name: "queue_incoming_pods_total", Help: "Number of pods added to scheduling queues by event and queue type.", StabilityLevel: metrics.STABLE, }, []string{"queue", "event"}) PermitWaitDuration = metrics.NewHistogramVec( &metrics.HistogramOpts{ Subsystem: SchedulerSubsystem,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 08:22:53 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner.go
}, }, options.SecretResync, ) return e, nil } // Run runs controller loops and returns when they are done func (e *Signer) Run(ctx context.Context) { // Shut down queues defer utilruntime.HandleCrash() defer e.syncQueue.ShutDown() if !cache.WaitForNamedCacheSync("bootstrap_signer", ctx.Done(), e.configMapSynced, e.secretSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0)