- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for HasWaiters (0.14 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_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)