- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 800 for queuesa (0.1 sec)
-
guava/src/com/google/common/base/internal/Finalizer.java
ReferenceQueue<Object> queue, PhantomReference<Object> frqReference) { this.queue = queue; this.finalizableReferenceClassReference = new WeakReference<>(finalizableReferenceClass); // Keep track of the FRQ that started us so we know when to stop. this.frqReference = frqReference; } /** Loops continuously, pulling references off the queue and cleaning them up. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Aug 23 12:54:09 UTC 2023 - 9.4K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta3/defaults.go
} } func SetDefaults_QueuingConfiguration(cfg *v1beta3.QueuingConfiguration) { if cfg.HandSize == 0 { cfg.HandSize = PriorityLevelConfigurationDefaultHandSize } if cfg.Queues == 0 { cfg.Queues = PriorityLevelConfigurationDefaultQueues } if cfg.QueueLengthLimit == 0 { cfg.QueueLengthLimit = PriorityLevelConfigurationDefaultQueueLengthLimit }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 3K bytes - Viewed (0) -
src/runtime/tracebuf.go
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 } // pop dequeues from the queue of buffers. func (q *traceBufQueue) pop() *traceBuf { buf := q.head if buf == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 6.8K bytes - Viewed (0) -
src/cmd/internal/edit/edit.go
if end < start || start < 0 || end > len(b.old) { panic("invalid edit position") } b.q = append(b.q, edit{start, end, new}) } // Bytes returns a new byte slice containing the original data // with the queued edits applied. func (b *Buffer) Bytes() []byte { // Sort edits by starting position and then by ending position. // Breaking ties by ending position allows insertions at point x
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 13 14:59:26 UTC 2017 - 2.5K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
key, quit := jm.queue.Get() if quit { return false } defer jm.queue.Done(key) requeueAfter, err := jm.sync(ctx, key) switch { case err != nil: utilruntime.HandleError(fmt.Errorf("error syncing CronJobController %v, requeuing: %w", key, err)) jm.queue.AddRateLimited(key) case requeueAfter != nil: jm.queue.Forget(key) jm.queue.AddAfter(key, *requeueAfter) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_replication_average_queued_bytes` | `gauge` | Average number of bytes queued for replication since server start | `server` | | `minio_replication_average_queued_count` | `gauge` | Average number of objects queued for replication since server start | `server` |
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 09:36:25 UTC 2024 - 40.9K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkQueueIntegrationTest.groovy
where: isolationMode << ISOLATION_MODES } def "errors in work submitted to other queues cause a task failure when waiting for work in #isolationMode"() { buildFile << """ task runWork(type: WorkItemTask) { doLast {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 8.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
T operation = firstOperation; while (operation != null) { if (queueState == QueueState.Cancelled) { // If an operation was pulled from the queue, but the queue was cancelled before this operation could start // (for instance, because this worker was waiting on a worker lease) discard it without running. return ++operationCount;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/console/ThrottlingOutputEventListenerTest.groovy
def listener = Mock(OutputEventListener) def clock = new MockClock() def executor = new MockExecutor() @Subject renderer = new ThrottlingOutputEventListener(listener, 100, executor, clock) def "queues events until update event received"() { def event1 = event('message') def event2 = event('message') when: renderer.onOutput(event1) renderer.onOutput(event2) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
} func (t *trackingWorkqueue[T]) queue(item T) { if _, queued := t.pendingMap[item]; queued { // fmt.Printf("already queued: %#v\n", item) return } t.pendingMap[item] = struct{}{} t.pendingList = append(t.pendingList, item) } func (t *trackingWorkqueue[T]) dequeue(item T) { if _, queued := t.pendingMap[item]; !queued { // fmt.Printf("not queued: %#v\n", item) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0)