- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 442 for Waiting (0.04 sec)
-
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
private final Executor adapterExecutor; // The execution list to hold our listeners. private final ExecutionList executionList = new ExecutionList(); // This allows us to only start up a thread waiting on the delegate future when the first // listener is added. private final AtomicBoolean hasListeners = new AtomicBoolean(false); // The delegate future. private final Future<V> delegate;Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 7.5K bytes - Viewed (0) -
docs/distributed/decom-encrypted-sse-s3.sh
./mc ls -r --versions myminio/versioned/ >expanded_ns_versions.txt ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1} until $(./mc admin decom status myminio/ | grep -q Complete); do echo "waiting for decom to finish..." sleep 1 done kill $pid_1 kill $pid_2 sleep 5 (minio server --address ":9001" http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/removed.log) & pid=$!Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
} throw firstException!! } /** * Returns non-null if we don't need to wait for the launched result. In such cases, this result * must be processed before whatever is waiting in the queue because we may have already acquired * its connection. */ private fun launchTcpConnect(): ConnectResult? { val plan = when { routePlanner.hasNext() -> { try {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocksProxy.kt
fun connectionCount(): Int = connectionCount.get() fun shutdown() { serverSocket!!.close() executor.shutdown() if (!executor.awaitTermination(5, TimeUnit.SECONDS)) { throw IOException("Gave up waiting for executor to shut down") } } private fun service(from: Socket) { val name = "SocksProxy ${from.remoteSocketAddress}" threadName(name) { try {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 7.6K bytes - Viewed (0) -
docs/es/docs/tutorial/index.md
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Tue Dec 16 16:33:45 UTC 2025 - 5.3K bytes - Viewed (0) -
docs/en/docs/tutorial/background-tasks.md
# Background Tasks { #background-tasks } You can define background tasks to be run *after* returning a response. This is useful for operations that need to happen after a request, but that the client doesn't really have to be waiting for the operation to complete before receiving the response. This includes, for example: * Email notifications sent after performing an action:Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 4.8K bytes - Viewed (0) -
docs/de/docs/fastapi-cli.md
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Tue Dec 02 17:32:56 UTC 2025 - 5K bytes - Viewed (0) -
docs/en/overrides/main.html
<a class="announce-link" href="https://fastapicloud.com" target="_blank"> <span class="twemoji"> {% include ".icons/material/cloud-arrow-up.svg" %} </span> Join the <strong>FastAPI Cloud</strong> waiting list 🚀 </a> </div> <div class="item"> <a class="announce-link" href="https://x.com/fastapi" target="_blank"> <span class="twemoji">
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Mon Dec 01 20:06:57 UTC 2025 - 5.5K bytes - Viewed (0) -
docs/en/docs/fastapi-cli.md
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 4.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
} }); thread.start(); // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load // (in startSignal.await()), and the others waiting for that thread's result. while (thread.isAlive() && thread.getState() != Thread.State.WAITING) { Thread.yield(); } } gettersStartedSignal.countDown(); gettersComplete.await();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 30 22:03:28 UTC 2025 - 91.1K bytes - Viewed (0)