- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 714 for Completer (0.56 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
final Completion completed; AbstractTimedLatch(long countdownInMillis) { this.completed = new Completion(countdownInMillis); } /** Awaits the latch and asserts that operation completed in the expected timeframe. */ final void awaitSuccessfully() { awaitLatchUninterruptibly(); completed.assertCompletionExpected(); assertEquals(0, getCount());Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 38.1K bytes - Click Count (0) -
docs/distributed/DECOMMISSION.md
``` ## Restart a canceled or failed decommission ``` λ mc admin decommission start alias/ http://minio{1...2}/data{1...4} ``` ## When decommission is 'Complete' Once decommission is complete, it will be indicated with *Complete* status. *Complete* means that now you can now safely remove the first pool argument from the MinIO command line. ``` λ mc admin decommission status alias/Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Jul 11 14:59:49 GMT 2022 - 8.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt
if (entry.currentEditor == this) { if (civilizedFileSystem) { completeEdit(this, false) // Delete it now. } else { entry.zombie = true // We can't delete it until the current edit completes. } } } /** * Returns an unbuffered input stream to read the last committed value, or null if no value has * been committed. */
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 34.7K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java
if (pointer instanceof Lifecycle.DependenciesPointer) { // For dependencies: ensure current project's phase starts after dependency's phase completes // Example: project's compile starts after dependency's package completes // TODO: String scope = ((Lifecycle.DependenciesPointer) pointer).scope(); projects.get(project)
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Oct 16 06:12:36 GMT 2025 - 55.1K bytes - Click Count (0) -
docs/zh/docs/deployment/server-workers.md
<span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span> Application startup complete. <span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span> Application startup complete. <span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span> Application startup complete. ``` </div> ////
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 17:06:37 GMT 2026 - 8K bytes - Click Count (0) -
docs/es/docs/deployment/server-workers.md
<span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span> Application startup complete. <span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span> Application startup complete. <span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span> Application startup complete. ``` </div> ////
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 8.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
assertFalse(sleeper.completed); assertTrue(getUninterruptibly(delayedFuture)); assertTrue(Thread.interrupted()); // clears the interrupt state, too assertTrue(sleeper.completed); } private static class SleepingRunnable implements Runnable { final int millis; volatile boolean completed; SleepingRunnable(int millis) { this.millis = millis;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.9K bytes - Click Count (0) -
tests/test_dependency_contextmanager.py
state["/async"] = "asyncgen started" yield state["/async"] state["/async"] = "asyncgen completed" def generator_state(state: dict[str, str] = Depends(get_state)): state["/sync"] = "generator started" yield state["/sync"] state["/sync"] = "generator completed" async def asyncgen_state_try(state: dict[str, str] = Depends(get_state)):
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 11.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java
} public void complete(RuntimeException e) { if (!super.setException(new WrapperException(checkNotNull(e)))) { throw new IllegalStateException("Future was already complete: " + this); } } public void complete(Error e) { if (!super.setException(new WrapperException(checkNotNull(e)))) { throw new IllegalStateException("Future was already complete: " + this); } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.3K bytes - Click Count (0) -
docs/pt/docs/deployment/server-workers.md
<span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span> Application startup complete. <span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span> Application startup complete. <span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span> Application startup complete. ``` </div> ////
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:20:43 GMT 2026 - 8.5K bytes - Click Count (0)