- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for HasWaiters (0.15 sec)
-
guava-tests/test/com/google/common/util/concurrent/TestThread.java
checkNotNull(conditionLikeObject); // TODO: Restore the following line when Monitor.hasWaiters() no longer acquires the lock. // assertEquals(false, invokeMethod("hasWaiters", conditionLikeObject)); sendRequest(methodName, conditionLikeObject); Thread.sleep(DUE_DILIGENCE_MILLIS); assertEquals(true, invokeMethod("hasWaiters", conditionLikeObject)); assertNull(responseQueue.poll()); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
checkNotNull(conditionLikeObject); // TODO: Restore the following line when Monitor.hasWaiters() no longer acquires the lock. // assertEquals(false, invokeMethod("hasWaiters", conditionLikeObject)); sendRequest(methodName, conditionLikeObject); Thread.sleep(DUE_DILIGENCE_MILLIS); assertEquals(true, invokeMethod("hasWaiters", conditionLikeObject)); assertNull(responseQueue.poll()); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/loop_test.go
if err := loopConditionUntilContext(ctx, timerWithClock(backoff.Timer(), fakeClock), false, true, f.WithContext()); err == nil || err != expectedError { t.Errorf("unexpected error: %v", err) } }() for !fakeClock.HasWaiters() { time.Sleep(time.Microsecond) } fakeClock.Step(time.Second - time.Millisecond) if attempt != 0 { t.Fatalf("should still be waiting for condition") } fakeClock.Step(2 * time.Millisecond)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 02:48:08 UTC 2023 - 15.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
* and leaves, calling signalNextWaiter. With traditional locks and conditions, all the conditions * need to be signalled because it is not known which if any of them have waiters (and hasWaiters * can't be used reliably because of a check-then-act race). With our Monitor guards, we only * signal the first active guard that is satisfied. But the corresponding thread may have already
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
* and leaves, calling signalNextWaiter. With traditional locks and conditions, all the conditions * need to be signalled because it is not known which if any of them have waiters (and hasWaiters * can't be used reliably because of a check-then-act race). With our Monitor guards, we only * signal the first active guard that is satisfied. But the corresponding thread may have already
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go
defer store.Stop() fc := store.clock.(*testingclock.FakeClock) // In background, step clock after the below call starts the timer. go func() { for !fc.HasWaiters() { time.Sleep(time.Millisecond) } store.Add(makeTestPod("foo", 2)) store.bookmarkRevision <- 3 fc.Step(blockTimeout) // Add an object to make sure the test would
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 35.4K bytes - Viewed (0)