- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 681 for Kuwait (0.23 sec)
-
cmd/data-scanner.go
// proceed to heal nonetheless, since // this object might be dangling. entry, _ = entries.firstFound() } wait := noWait if f.weSleep() { // wait timer per object. wait = scannerSleeper.Timer(ctx) } defer wait() f.updateCurrentPath(entry.name) stopFn := globalScannerMetrics.log(scannerMetricHealAbandonedObject, f.root, entry.name)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
docs/es/docs/async.md
# Concurrencia y async / await Detalles sobre la sintaxis `async def` para *path operation functions* y un poco de información sobre código asíncrono, concurrencia y paralelismo. ## ¿Tienes prisa? <abbr title="too long; didn't read"><strong>TL;DR:</strong></abbr> Si estás utilizando libraries de terceros que te dicen que las llames con `await`, del tipo: ```Python results = await some_library() ```
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 24.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
} }, "ProcessCloser-output-" + sessionId).start(); try { latch.await(10, TimeUnit.SECONDS); } catch (final InterruptedException e) { logger.warn("Interrupted to wait a process.", e); } try { process.destroyForcibly().waitFor(processDestroyTimeout, TimeUnit.SECONDS);
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
functionBlocking.await(); return immediateFuture(null); } }); ExecutorService executor = Executors.newSingleThreadExecutor(); try { ListenableFuture<?> output = Futures.transformAsync(immediateFuture(null), function, executor); functionCalled.await(); assertThat(output.toString()).contains(function.toString());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K 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();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
afterStarted.countDown(); // We do not call awaitHealthy because, due to races, that method may throw an exception. But // we really just want to wait for the thread to be in the failure callback so we wait for that // explicitly instead. failEnter.await(); assertFalse("State should be updated before calling listeners", manager.isHealthy()); // now we want to stop the services. Thread stoppingThread =
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // RST_STREAM peer.acceptFrame() // DEGRADED PING peer.acceptFrame() // AWAIT PING peer.sendFrame().ping(true, Http2Connection.DEGRADED_PING, 1) // DEGRADED PONG peer.sendFrame().ping(true, Http2Connection.AWAIT_PING, 0) // AWAIT PONG peer.play() // Play it back. val connection = connect(peer)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
awaitPingsSent++ } // 0x4f 0x4b 0x6f 0x6b is "OKok". writePing(false, AWAIT_PING, 0x4f4b6f6b) } /** For testing: awaits a pong. */ @Throws(InterruptedException::class) fun awaitPong() { this.withLock { while (awaitPongsReceived < awaitPingsSent) { condition.await() } } } @Throws(IOException::class) fun flush() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 23.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheBuilderTest.java
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 25.5K bytes - Viewed (0)