- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 11 for blockedOn (0.05 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
private static final long SMALL_TIMEOUT_MILLIS = 10; /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */ private static final long EXPECTED_HANG_DELAY_MILLIS = 75; /** * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked. */ private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000; /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 27.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
sendRequest(methodName, arguments); assertThat(getResponse(methodName).getThrowable()).isInstanceOf(expected); } /** * Causes this thread to call the named method, and asserts that this thread becomes blocked on * the lock-like object. The lock-like object must have a method equivalent to {@link * java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}. */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 11.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* state: BLOCKED, WAITING, or TIMED_WAITING. */ @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait. void waitForThreadToEnterWaitState(Thread thread, long timeoutMillis) { long startTime = System.nanoTime(); for (; ; ) { Thread.State s = thread.getState();Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:07:52 GMT 2025 - 37.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
sendRequest(methodName, arguments); assertThat(getResponse(methodName).getThrowable()).isInstanceOf(expected); } /** * Causes this thread to call the named method, and asserts that this thread becomes blocked on * the lock-like object. The lock-like object must have a method equivalent to {@link * java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}. */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 11.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
@SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait. void awaitTimedWaiting(Thread thread) { while (true) { switch (thread.getState()) { case BLOCKED: case NEW: case RUNNABLE: case WAITING: Thread.yield(); break; case TIMED_WAITING: return; case TERMINATED:Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Dec 12 00:25:21 GMT 2025 - 26.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// This should wake up waiter1 and cause the waiter1 node to be removed. waiter1.interrupt(); waiter1.join(); waiter2.awaitWaiting(); // should still be blocked LockSupport.unpark(waiter2); // spurious wakeup waiter2.awaitWaiting(); // should eventually re-park future.set(null); waiter2.join(); }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// This should wake up waiter1 and cause the waiter1 node to be removed. waiter1.interrupt(); waiter1.join(); waiter2.awaitWaiting(); // should still be blocked LockSupport.unpark(waiter2); // spurious wakeup waiter2.awaitWaiting(); // should eventually re-park future.set(null); waiter2.join(); }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
@SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait. void awaitTimedWaiting(Thread thread) { while (true) { switch (thread.getState()) { case BLOCKED: case NEW: case RUNNABLE: case WAITING: Thread.yield(); break; case TIMED_WAITING: return; case TERMINATED:Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Dec 12 00:25:21 GMT 2025 - 26.5K bytes - Click Count (0) -
CHANGELOG.md
intend to ship a public API for these features, but we don't want to hold OkHttp 5.0.0 until those APIs are stable. * Fix: Change `MockWebServer.close()` to cancel ongoing calls that are blocked on a delay. * Upgrade: [Okio 3.13.0][okio_3_13_0]. This release also stabilizes many APIs in the `mockwebserver3` artifact that's new in 5.0.
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 05 16:02:59 GMT 2025 - 36.2K bytes - Click Count (2) -
CHANGELOG/CHANGELOG-1.35.md
- Added the correct error when eviction is blocked due to the failSafe mechanism of the `DisruptionController`. ([#133097](https://github.com/kubernetes/kubernetes/pull/133097), [@kei01234kei](https://github.com/kei01234kei)) [SIG Apps and Node]
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Wed Dec 17 13:01:55 GMT 2025 - 228.5K bytes - Click Count (0)