- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for HasWaiters (0.36 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/apiserver/pkg/storage/cacher/watch_progress_test.go
pr := newTestConditionalProgressRequester(clock) stopCh := make(chan struct{}) go pr.Run(stopCh) var wantRequestsSent int32 var requestsSent int32 logger.Info("Wait for ticker to be created") for !clock.HasWaiters() { time.Sleep(pollPeriod) } logger.Info("No progress requests if no-one is waiting") clock.Step(progressRequestPeriod * 2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 4.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
Monitor monitor1 = new Monitor(); Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2); assertThrows(IllegalMonitorStateException.class, () -> monitor1.hasWaiters(guard)); } public void testNullMonitorInGuardConstructorThrowsNPE() { assertThrows(NullPointerException.class, () -> new FlagGuard(null)); } public void testIsFair() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 4.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
Monitor monitor1 = new Monitor(); Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2); assertThrows(IllegalMonitorStateException.class, () -> monitor1.hasWaiters(guard)); } public void testNullMonitorInGuardConstructorThrowsNPE() { assertThrows(NullPointerException.class, () -> new FlagGuard(null)); } public void testIsFair() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 4.9K 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) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1)