- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 5,653 for waiting (0.04 sec)
-
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
@Override protected void tearDown() throws Exception { // Make sure we have no waiting threads. latch.countDown(); } /** Constructs a listenable future with a value available after the latch has counted down. */ protected abstract <V> ListenableFuture<V> createListenableFuture( V value, @Nullable Exception except, CountDownLatch waitOn); /** Tests that the {@link Future#get()} method blocks until a value is available. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
* @param timeoutMillis * The time to wait (in milliseconds) * @return <code>true</code> if the thread has terminated * @throws InterruptedException * If interrupted while waiting */ public boolean stop(final long timeoutMillis) throws InterruptedException { final Thread t = this.thread; synchronized (this) { if (t == null) { return true;
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 7.8K bytes - Viewed (0) -
docs/pt/docs/tutorial/index.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Thu Jan 09 20:41:07 UTC 2025 - 4.8K bytes - Viewed (0) -
docs/en/docs/fastapi-cli.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 4.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt
} else { events.add(Failure(t, response)) } } private fun nextEvent(): Any = events.poll(10, TimeUnit.SECONDS) ?: throw AssertionError("Timed out waiting for event.") fun assertTextMessage(payload: String?) { assertThat(nextEvent()).isEqualTo(Message(string = payload)) } fun assertBinaryMessage(payload: ByteString?) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6.8K bytes - Viewed (0) -
cmd/leak-detect_test.go
} // DetectLeak - Creates a snapshot of runtime stack and compares it with the initial stack snapshot. func (initialSnapShot LeakDetect) DetectLeak(t TestErrHandler) { if t.Failed() { return } // Loop, waiting for goroutines to shut down. // Wait up to 5 seconds, but finish as quickly as possible. deadline := UTCNow().Add(leakDetectDeadline * time.Second) for { // get sack snapshot of relevant go routines.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.2K bytes - Viewed (0) -
docs/es/docs/fastapi-cli.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 5K bytes - Viewed (0) -
docs/en/docs/advanced/events.md
/// /// tip Notice that in this case we are using a standard Python `open()` function that interacts with a file. So, it involves I/O (input/output), that requires "waiting" for things to be written to disk. But `open()` doesn't use `async` and `await`. So, we declare the event handler function with standard `def` instead of `async def`. ///
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 7.9K bytes - Viewed (0) -
docs/uk/docs/fastapi-cli.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Tue Dec 17 21:33:34 UTC 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt
} } private fun readAndWriteFrames() { check(socket == null) val socket = serverSocket!!.accept()!! this.socket = socket // Bail out now if this instance was closed while waiting for the socket to accept. synchronized(this) { if (executor.isShutdown) { socket.close() return } } val outputStream = socket.getOutputStream()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 8.7K bytes - Viewed (0)