- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 301 for iowait (0.36 sec)
-
cmd/admin-heal-ops.go
if source.noWait { select { case globalBackgroundHealRoutine.tasks <- task: if serverDebugLog { fmt.Printf("Task in the queue: %#v\n", task) } default: // task queue is full, no more workers, we shall move on and heal later. return nil } // Don't wait for result return nil } // respCh must be set to wait for result.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
*/ @GuardedBy("lock") private void await(Guard guard, boolean signalBeforeWaiting) throws InterruptedException { if (signalBeforeWaiting) { signalNextWaiter(); } beginWaitingFor(guard); try { do { guard.condition.await(); } while (!guard.isSatisfied()); } finally { endWaitingFor(guard); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Dec 04 18:22:01 GMT 2023 - 38.6K bytes - Viewed (0) -
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) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
(this as Object).notifyAll() } /** * Returns the recorded response triggered by `request`. Throws if the response isn't * enqueued before the timeout. */ @Synchronized fun await(url: HttpUrl): RecordedResponse { val timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS while (true) { val i = responses.iterator() while (i.hasNext()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
std::unique_ptr<TF_Status, decltype(&TF_DeleteStatus)> await_status( TF_NewStatus(), TF_DeleteStatus); // Wait until all pending nodes have completed since they may have a // reference to default_cancellation_manager_. We ignore the status return // since we already have a bad status to propagate. TFE_ContextAsyncWait(context, await_status.get());
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Feb 09 07:47:20 GMT 2024 - 25.4K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null; } public void waitForStart() throws InterruptedException { startLatch.await(); } public void stop() { stopLatch.countDown(); } public boolean isRunning() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null; } public void waitForStart() throws InterruptedException { startLatch.await(); } public void stop() { stopLatch.countDown(); } public boolean isRunning() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K 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) -
docs/en/docs/async.md
```Python burgers = await get_burgers(2) ``` The key here is the `await`. It tells Python that it has to wait ⏸ for `get_burgers(2)` to finish doing its thing 🕙 before storing the results in `burgers`. With that, Python will know that it can go and do something else 🔀 ⏯ in the meanwhile (like receiving another request).
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 23K bytes - Viewed (0)