- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 800 for queuesa (0.19 sec)
-
staging/src/k8s.io/api/testdata/v1.29.0/flowcontrol.apiserver.k8s.io.v1beta2.PriorityLevelConfiguration.yaml
limited: assuredConcurrencyShares: 1 borrowingLimitPercent: 4 lendablePercent: 3 limitResponse: queuing: handSize: 2 queueLengthLimit: 3 queues: 1 type: typeValue type: typeValue status: conditions: - lastTransitionTime: "2003-01-01T01:01:01Z" message: messageValue reason: reasonValue status: statusValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 04:12:07 UTC 2023 - 1.3K 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) -
guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
final L listener; final Executor executor; @GuardedBy("this") final Queue<ListenerCallQueue.Event<L>> waitQueue = Queues.newArrayDeque(); @GuardedBy("this") final Queue<Object> labelQueue = Queues.newArrayDeque(); @GuardedBy("this") boolean isThreadScheduled; PerListenerQueue(L listener, Executor executor) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestQueueGenerator.java
import java.util.Queue; import org.checkerframework.checker.nullness.qual.Nullable; /** * Creates queues, containing sample elements, to be tested. * * @author Jared Levy */ @GwtCompatible @ElementTypesAreNonnullByDefault public interface TestQueueGenerator<E extends @Nullable Object> extends TestCollectionGenerator<E> { @Override Queue<E> create(Object... elements);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 21 16:49:06 UTC 2024 - 1.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered_test.go
backend.ProcessEvents(newEvents(1)...) tc := make(chan time.Time) wg := sync.WaitGroup{} wg.Add(1) go func() { defer wg.Done() batch = backend.collectEvents(tc, nil) }() // Wait for the queued events to be collected. err := wait.Poll(time.Second, wait.ForeverTestTimeout, func() (bool, error) { return len(backend.buffer) == 0, nil }) require.NoError(t, err) tc <- time.Now() // Trigger "timeout"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 14 17:20:35 UTC 2018 - 5.9K bytes - Viewed (0) -
guava/src/com/google/common/collect/MapMakerInternalMap.java
WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) { super(referent, queue); this.entry = entry; } @Override public E getEntry() { return entry; } @Override public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) { return new WeakValueReferenceImpl<>(queue, get(), entry); } } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0) -
src/regexp/exec.go
import ( "io" "regexp/syntax" "sync" ) // A queue is a 'sparse array' holding pending threads of execution. // See https://research.swtch.com/2008/03/using-uninitialized-memory-for-fun-and.html type queue struct { sparse []uint32 dense []entry } // An entry is an entry on a queue. // It holds both the instruction pc and the actual thread. // Some queue entries are just place holders so that the machine
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Jun 04 20:10:54 UTC 2022 - 12.3K bytes - Viewed (0) -
pkg/util/async/bounded_frequency_runner_test.go
checkReceiver("init", t, obj, false) // Run once, immediately, and queue a retry // rel=0ms obj.setRetryFn(func() { runner.RetryAfter(5 * time.Second) }) runner.Run() waitForRunWithRetry("first run", t, timer, obj, 5*time.Second) // Nothing happens... timer.advance(time.Second) // rel=1000ms waitForNothing("minInterval, nothing queued", t, timer, obj) // After retryInterval, function is called
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 12.5K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
* on single thread, keeping the listener logic simple. This listener also blocks on last transfer event to allow * output to perform possible cleanup. It spawns a daemon thread to consume queued events that may fall in even * concurrently. * * @since 4.0.0 */ public final class SimplexTransferListener extends AbstractTransferListener {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/composite/internal/IncludedBuildTaskResource.java
} public boolean isComplete() { return complete; } } /** * Queues the task for execution, but does not schedule it. Use {@link org.gradle.internal.buildtree.BuildTreeWorkGraph#scheduleWork(Consumer)} to schedule queued tasks. */ void queueForExecution(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 12 20:10:34 UTC 2022 - 1.7K bytes - Viewed (0)