- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 982 for nwait (0.06 sec)
-
src/runtime/sema.go
} for { lockWithRank(&root.lock, lockRankRoot) // Add ourselves to nwait to disable "easy case" in semrelease. root.nwait.Add(1) // Check cansemacquire to avoid missed wakeup. if cansemacquire(addr) { root.nwait.Add(-1) unlock(&root.lock) break } // Any semrelease after the cansemacquire knows we're waiting // (we set nwait above), so go to sleep. root.queue(addr, s, lifo)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K bytes - Viewed (0) -
src/runtime/export_test.go
return &root.lock } var Semacquire = semacquire var Semrelease1 = semrelease1 func SemNwait(addr *uint32) uint32 { root := semtable.rootFor(addr) return root.nwait.Load() } const SemTableSize = semTabSize // SemTable is a wrapper around semTable exported for testing. type SemTable struct { semTable }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:50:53 UTC 2024 - 46.1K 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) -
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) -
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 (1) -
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) -
docs/en/docs/async.md
```Python burgers = await get_burgers(2) ``` The key here is the `await`. It tells Python that it has to wait ⏸ for `get_burgers(2)` to finish doing its thing 🕙 before storing the results in `burgers`. With that, Python will know that it can go and do something else 🔀 ⏯ in the meanwhile (like receiving another request).
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Mon May 20 00:24:48 UTC 2024 - 23K 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) -
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) -
guava/src/com/google/common/util/concurrent/Uninterruptibles.java
/** Invokes {@code latch.}{@link CountDownLatch#await() await()} uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency public static void awaitUninterruptibly(CountDownLatch latch) { boolean interrupted = false; try { while (true) { try { latch.await(); return; } catch (InterruptedException e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 18.7K bytes - Viewed (0)