- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 638 for queuesa (0.58 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
var minQueue *queue var minIndex int nq := len(qs.queues) for range qs.queues { qs.robinIndex = (qs.robinIndex + 1) % nq queue := qs.queues[qs.robinIndex] oldestWaiting, _ := queue.requestsWaiting.Peek() if oldestWaiting != nil { sMin = min(sMin, queue.nextDispatchR) sMax = max(sMax, queue.nextDispatchR)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
* * @param queue the queue to be wrapped in a synchronized view * @return a synchronized view of the specified queue * @since 14.0 */ public static <E extends @Nullable Object> Queue<E> synchronizedQueue(Queue<E> queue) { return Synchronized.queue(queue, null); } /** * Returns a synchronized (thread-safe) deque backed by the specified deque. In order to guarantee
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 16K bytes - Viewed (0) -
guava/src/com/google/common/collect/Queues.java
* * @param queue the queue to be wrapped in a synchronized view * @return a synchronized view of the specified queue * @since 14.0 */ public static <E extends @Nullable Object> Queue<E> synchronizedQueue(Queue<E> queue) { return Synchronized.queue(queue, null); } /** * Returns a synchronized (thread-safe) deque backed by the specified deque. In order to guarantee
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 18K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/doc.go
// request executing: the last virtual finish time is the queue’s // virtual start time. When a request is dequeued for service the // queue’s virtual start time is advanced by G. When a request // finishes being served, and the actual service time was S, the // queue’s virtual start time is decremented by G - S.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 12:33:30 UTC 2024 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/types.go
// index is the position of this queue among those in its queueSet. index int // seatsInUse is the total number of "seats" currently occupied // by all the requests that are currently executing in this queue. seatsInUse int } // queueSum tracks the sum of initial seats, max seats, and // totalWork from all requests in a given queue type queueSum struct { // InitialSeatsSum is the sum of InitialSeats
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 17:38:43 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
log *istiolog.Scope } // WithName sets a name for the queue. This is used for logging func WithName(name string) func(q *Queue) { return func(q *Queue) { q.name = name } } // WithRateLimiter allows defining a custom rate limiter for the queue func WithRateLimiter(r workqueue.RateLimiter) func(q *Queue) { return func(q *Queue) { q.queue = workqueue.NewRateLimitingQueue(r) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
coordinationService.withStateLock(() -> queue.abortAllAndFail(failure)); } /** * Blocks until all items in the queue have been processed. This method will only return when every item in the queue has either completed, failed or been skipped. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
QueueLengthLimit int // HandSize is a parameter of shuffle sharding. Upon arrival of a request, a queue is chosen by randomly // dealing a "hand" of this many queues and then picking one of minimum length. HandSize int } // DispatchingConfig defines the configuration of the dispatching aspect of a QueueSet. type DispatchingConfig struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
internal/event/config_test.go
</S3Key> </Filter> <Queue>arn:minio:sqs::1:webhook</Queue> <Event>s3:ObjectCreated:Put</Event> </QueueConfiguration>`) queue2 := &Queue{} if err := xml.Unmarshal(data, queue2); err != nil { panic(err) } testCases := []struct { queue *Queue region string expectedResult ARN }{ {queue1, "eu-west-1", ARN{TargetID{"1", "webhook"}, "eu-west-1"}},
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 29K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller_debug.go
if !ok { continue } queueSetDigest := plState.queues.Dump(false) activeQueueNum := 0 for _, q := range queueSetDigest.Queues { if len(q.Requests) > 0 { activeQueueNum++ } } tabPrint(tabWriter, rowForPriorityLevel( plState.pl.Name, // 1 activeQueueNum, // 2 plState.queues.IsIdle(), // 3 plState.quiescing, // 4
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 17:38:43 UTC 2023 - 7.9K bytes - Viewed (0)