- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 661 for executions (0.05 sec)
-
docs/en/docs/tutorial/dependencies/dependencies-with-yield.md
## Execution of dependencies with `yield` { #execution-of-dependencies-with-yield } The sequence of execution is more or less like this diagram. Time flows from top to bottom. And each column is one of the parts interacting or executing code. ```mermaid sequenceDiagram participant client as Client
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 12.7K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbSessionImplSecurityTest.java
assertTrue(endLatch.await(30, TimeUnit.SECONDS), "All threads should complete within timeout"); executor.shutdown(); // Then - Verify no exceptions occurred if (!exceptions.isEmpty()) { fail("Concurrent operations caused exceptions: " + exceptions.get(0)); } assertEquals(threadCount * opsPerThread, successCount.get(), "All operations should succeed"); } /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 11K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt
} val isRunning = promoteAndExecute() if (!isRunning && idleCallback != null) { idleCallback.run() } } /** Returns a snapshot of the calls currently awaiting execution. */ @Synchronized fun queuedCalls(): List<Call> = readyAsyncCalls.map { it.call }.unmodifiable() /** Returns a snapshot of the calls currently being executed. */ @Synchronized
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 8.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* * <p>Tasks submitted to {@link #execute(Runnable)} are executed in FIFO order. * * <p>The execution of tasks is done by one thread as long as there are tasks left in the queue. * When a task is {@linkplain Thread#interrupt interrupted}, execution of subsequent tasks * continues. See {@link QueueWorker#workOnQueue} for details. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 10.6K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* complete} or, if the computation is already complete, immediately. * * <p>There is no guaranteed ordering of execution of listeners, but any listener added through * this method is guaranteed to be called once the computation is complete. * * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* complete} or, if the computation is already complete, immediately. * * <p>There is no guaranteed ordering of execution of listeners, but any listener added through * this method is guaranteed to be called once the computation is complete. * * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
/** * Returns a snapshot of tasks currently scheduled for execution. Does not include the * currently-executing task unless it is also scheduled for future execution. */ val scheduledTasks: List<Task> get() = taskRunner.withLock { futureTasks.toList() } /** * Schedules [task] for execution in [delayNanos]. A task may only have one future execution
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 7.3K bytes - Viewed (0) -
src/main/java/org/codelibs/core/lang/ThreadUtil.java
/** * Do not instantiate. */ protected ThreadUtil() { } /** * Causes the currently executing thread to sleep (temporarily cease execution) for the specified number of milliseconds. * * @param millis * the length of time to sleep in milliseconds * @throws InterruptedRuntimeException
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 2.3K bytes - Viewed (0) -
src/test/java/jcifs/smb/CriticalPerformanceTest.java
System.out.printf(" Avg tree operation time: %.2f ns%n", avgOpTimeNs); // Verify thread safety and performance assertTrue(exceptions.isEmpty(), "No exceptions should occur with thread-safe collections: " + exceptions); assertEquals(threadCount * operationsPerThread, treeOperations.get()); assertTrue(avgOpTimeNs < 100000, "Tree operations should be reasonable with CopyOnWriteArrayList");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 15.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
return task; } /** * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that * will complete after execution. * * @throws RejectedExecutionException if the task cannot be scheduled for execution * @since 28.2 */ public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) { TrustedListenableFutureTask<@Nullable Void> task =
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0)