- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,948 for waits (0.27 sec)
-
android/guava/src/com/google/common/util/concurrent/Service.java
void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException; /** * Waits for the {@link Service} to reach the {@linkplain State#TERMINATED terminated state}. * * @throws IllegalStateException if the service {@linkplain State#FAILED fails}. * @since 15.0 */ void awaitTerminated(); /** * Waits for the {@link Service} to reach a terminal state (either {@link Service.State#TERMINATED
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 10.7K bytes - Viewed (0) -
test/chan/select6.go
// Test for select: Issue 2075 // A bug in select corrupts channel queues of failed cases // if there are multiple waiters on those channels and the // select is the last in the queue. If further waits are made // on the channel without draining it first then those waiters // will never wake up. In the code below c1 is such a channel. package main func main() { c1 := make(chan bool) c2 := make(chan bool)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 783 bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
protected CountDownLatch latch; protected ListenableFuture<Boolean> future; @Override protected void setUp() throws Exception { // Create a latch and a future that waits on the latch. latch = new CountDownLatch(1); future = createListenableFuture(Boolean.TRUE, null, latch); } @Override protected void tearDown() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue9400_linux.go
} // Disable GC for the duration of the test. // This avoids a potential GC deadlock when spinning in uninterruptible ASM below #49695. defer debug.SetGCPercent(debug.SetGCPercent(-1)) // SetGCPercent waits until the mark phase is over, but the runtime // also preempts at the start of the sweep phase, so make sure that's // done too. See #49695. runtime.GC() // Temporarily rewind the stack and trigger SIGSETXID
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/test/kube/util.go
gracePeriod := int64(0) return metav1.DeleteOptions{ PropagationPolicy: &propagationPolicy, GracePeriodSeconds: &gracePeriod, } } // WaitUntilPodsAreReady waits until the pod with the name/namespace is in ready state. func WaitUntilPodsAreReady(fetchFunc PodFetchFunc, opts ...retry.Option) ([]corev1.Pod, error) { var pods []corev1.Pod err := retry.UntilSuccess(func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 9.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
protected CountDownLatch latch; protected ListenableFuture<Boolean> future; @Override protected void setUp() throws Exception { // Create a latch and a future that waits on the latch. latch = new CountDownLatch(1); future = createListenableFuture(Boolean.TRUE, null, latch); } @Override protected void tearDown() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/ConditionalExecutionQueue.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.5K bytes - Viewed (0) -
istioctl/pkg/util/common.go
type CommandParseError struct { Err error } func (c CommandParseError) Error() string { return c.Err.Error() } // Confirm waits for a user to confirm with the supplied message. func Confirm(msg string, writer io.Writer) bool { for { _, _ = fmt.Fprintf(writer, "%s ", msg) var response string _, err := fmt.Scanln(&response) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 1.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
try { return satisfied = guard.isSatisfied(); } finally { if (!satisfied) { lock.unlock(); } } } /** * Waits for the guard to be satisfied. Waits indefinitely, but may be interrupted. May be called * only by a thread currently occupying this monitor. * * @throws InterruptedException if interrupted while waiting */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0) -
pkg/util/async/runner.go
limitations under the License. */ package async import ( "sync" ) // Runner is an abstraction to make it easy to start and stop groups of things that can be // described by a single function which waits on a channel close to exit. type Runner struct { lock sync.Mutex loopFuncs []func(stop chan struct{}) stop *chan struct{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 29 06:37:00 UTC 2016 - 1.4K bytes - Viewed (0)