- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 498 for bgwait (0.93 sec)
-
src/cmd/dist/util.go
bgwork <- func() { defer wg.Done() run(dir, CheckExit|ShowOutput|Background, cmd...) } } // bgwait waits for pending bgruns to finish. // bgwait must be called from only a single goroutine at a time. func bgwait(wg *sync.WaitGroup) { done := make(chan struct{}) go func() { wg.Wait() close(done) }() select { case <-done: case <-dying:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 23 17:50:29 UTC 2023 - 11.2K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/kubernetes" kctldeployment "k8s.io/kubectl/pkg/util/deployment" "istio.io/istio/operator/pkg/name" "istio.io/istio/operator/pkg/object" "istio.io/istio/operator/pkg/util/progress" "istio.io/istio/pkg/kube" ) const ( // defaultWaitResourceTimeout is the maximum wait time for all resources(namespace/deployment/pod) to be created.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
istioctl experimental wait --for=distribution virtualservice bookinfo.default # Wait until the bookinfo virtual service has been distributed to a specific proxy istioctl experimental wait --for=distribution virtualservice bookinfo.default --proxy workload-instance.namespace # Wait until 99% of the proxies receive the distribution, timing out after 5 minutes
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 12:24:17 UTC 2024 - 10.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
return nil } // WaitForPodsWithLabel will lookup pods with the given label and wait until they are all // reporting status as running. func (w *KubeWaiter) WaitForPodsWithLabel(kvLabel string) error { lastKnownPodNumber := -1 return wait.PollUntilContextTimeout(context.Background(), constants.KubernetesAPICallRetryInterval, w.timeout,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
service.startAsync().awaitRunning(); for (int i = 1; i < 10; i++) { service.runFirstBarrier.await(); assertEquals(i, service.numberOfTimesRunCalled.get()); service.runSecondBarrier.await(); } service.runFirstBarrier.await(); service.stopAsync(); service.runSecondBarrier.await(); service.stopAsync().awaitTerminated(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 22.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
service.startAsync().awaitRunning(); for (int i = 1; i < 10; i++) { service.runFirstBarrier.await(); assertEquals(i, service.numberOfTimesRunCalled.get()); service.runSecondBarrier.await(); } service.runFirstBarrier.await(); service.stopAsync(); service.runSecondBarrier.await(); service.stopAsync().awaitTerminated(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 22.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
// WAIT #1 barrier.await(1, TimeUnit.SECONDS); // WAIT #2 barrier.await(1, TimeUnit.SECONDS); assertTrue(executor.isShutdown()); assertFalse(executor.isTerminated()); // WAIT #3
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 28.2K bytes - Viewed (0) -
docs/tr/docs/async.md
# Concurrency ve async / await *path operasyon fonksiyonu* için `async def `sözdizimi, asenkron kod, eşzamanlılık ve paralellik hakkında bazı ayrıntılar. ## Aceleniz mi var? <abbr title="too long; didn't read"><strong>TL;DR:</strong></abbr> Eğer `await` ile çağrılması gerektiğini belirten üçüncü taraf kütüphaneleri kullanıyorsanız, örneğin: ```Python results = await some_library() ```
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 21.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
// WAIT #1 barrier.await(1, TimeUnit.SECONDS); // WAIT #2 barrier.await(1, TimeUnit.SECONDS); assertTrue(executor.isShutdown()); assertFalse(executor.isTerminated()); // WAIT #3
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 28.2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/util/ConcurrentSpecificationTest.groovy
def latch = new CountDownLatch(1) Runnable action = Mock() when: operation.start { action.run() latch.await() } then: 1 * action.run() >> { operation.callbackLater { latch.await() } } cleanup: latch.countDown() } @FailsWith(TooManyInvocationsError)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:50 UTC 2021 - 10.5K bytes - Viewed (0)