- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 816 for QUEUE (0.03 sec)
-
pkg/kube/controllers/example_test.go
// we have fully processed each item, not simply added it to the Queue. The queue exposes a // HasSynced method that returns true once all items added before queue.Run() was called are complete. // This means we must populate the initial state into the queue *before* we run it. // First, wait for pods to sync. Once this is complete, we know the event handler for Pods will have
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/reduce_while_operands.cc
const std::vector<std::vector<uint64_t>> &dependency_graph) { std::vector<uint64_t> queue; queue.reserve(is_consumed_id.size()); for (auto id : explicitly_consumed_ids) { is_consumed_id[id] = true; queue.push_back(id); } while (!queue.empty()) { auto i = queue.back(); queue.pop_back(); // If there is a consumer which cannot be found in dependency graph, return // false.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 10.4K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerExecutionQueueFactory.java
public synchronized ConditionalExecutionQueue<DefaultWorkResult> create() { if (queue == null) { queue = conditionalExecutionQueueFactory.create(QUEUE_DISPLAY_NAME, DefaultWorkResult.class); } return queue; } @Override public synchronized void stop() { if (queue != null) { queue.stop(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 1.9K bytes - Viewed (0) -
src/cmd/go/internal/mvs/graph.go
// that version is selected. func (g *Graph) WalkBreadthFirst(f func(m module.Version)) { var queue []module.Version enqueued := make(map[module.Version]bool) for _, m := range g.roots { if m.Version != "none" { queue = append(queue, m) enqueued[m] = true } } for len(queue) > 0 { m := queue[0] queue = queue[1:] f(m) reqs, _ := g.RequiredBy(m) for _, r := range reqs {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 01 02:52:19 UTC 2023 - 6.3K bytes - Viewed (0) -
platforms/native/platform-native/src/test/groovy/org/gradle/nativeplatform/toolchain/internal/swift/SwiftLinkerTest.groovy
1 * buildOperationExecutor.runAll(commandLineTool, _) >> { worker, action -> action.execute(queue) } 1 * invocationContext.getArgAction() >> Actions.doNothing() 1 * invocationContext.createInvocation("linking lib", outputFile.parentFile, expectedArgs, operationLogger) >> invocation 1 * queue.add(invocation) 1 * queue.setLogLocation(LOG_LOCATION) 0 * _ where:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 9K bytes - Viewed (0) -
internal/event/config_test.go
</S3Key> </Filter> <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue> <Event>s3:ObjectCreated:Put</Event> </QueueConfiguration>`) queue2 := &Queue{} if err := xml.Unmarshal(data, queue2); err != nil { panic(err) } data = []byte(` <QueueConfiguration> <Id>1</Id> <Filter></Filter> <Queue>arn:minio:sqs:eu-west-2:1:webhook</Queue> <Event>s3:ObjectAccessed:*</Event>
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 29K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
} @Test fun taskFailsWithUncheckedException() { queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(100)) { log.put("failing task running") throw RuntimeException("boom!") } queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) { log.put("normal task running") return@schedule -1L } queue.idleLatch().await(500, TimeUnit.MILLISECONDS)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
/** Returns the delay in nanoseconds until the next execution, or -1L to not reschedule. */ abstract fun runOnce(): Long internal fun initQueue(queue: TaskQueue) { if (this.queue === queue) return check(this.queue === null) { "task is in multiple queues" } this.queue = queue } override fun toString(): String = name
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go
} } // processNextWorkItem deals with one key off the queue. // It returns false when it's time to quit. func (ec *EstablishingController) processNextWorkItem() bool { key, quit := ec.queue.Get() if quit { return false } defer ec.queue.Done(key) err := ec.syncFn(key) if err == nil { ec.queue.Forget(key) return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/converter/ReadingConverterChain.java
final Queue<String> queue = new LinkedList<>(); queue.add(text); final List<String> convertedTexts = new ArrayList<>(getMaxReadingNum()); convertedTexts.add(text); for (final ReadingConverter converter : converters) { String s; while ((s = queue.poll()) != null && convertedTexts.size() <= getMaxReadingNum()) {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 1.9K bytes - Viewed (0)