- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,176 for executeOn (0.14 sec)
-
guava/src/com/google/common/util/concurrent/SequentialExecutor.java
import javax.annotation.CheckForNull; /** * Executor ensuring that all Runnables submitted are executed in order, using the provided * Executor, and sequentially such that no two will ever be running at the same time. * * <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.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
* that every {@code Runnable} that is {@linkplain #add added} will be executed after {@link * #execute()} is called. Any {@code Runnable} added after the call to {@code execute} is still * guaranteed to execute. There is no guarantee, however, that listeners will be executed in the * order that they are added. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Call.kt
* * @throws IOException if the request could not be executed due to cancellation, a connectivity * problem or timeout. Because networks can fail during an exchange, it is possible that the * remote server accepted the request before the failure. * @throws IllegalStateException when the call has already been executed. */ @Throws(IOException::class) fun execute(): Response /**
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 3.6K bytes - Viewed (0) -
okhttp/src/main/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.lock.withLock { futureTasks.toList() } /** * Schedules [task] for execution in [delayNanos]. A task may only have one future execution
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0) -
tensorflow/c/eager/c_api.h
// *num_retvals to the number of outputs. // // If async execution is enabled, the call may simply enqueue the execution // and return "non-ready" handles in `retvals`. Note that any handles contained // in 'op' should not be mutated till the kernel execution actually finishes. // // For sync execution, if any of the inputs to `op` are not ready, this call
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 22.8K bytes - Viewed (0) -
dbflute_fess/_readme.txt
Directory for DBFlute client manage.bat(sh) => 21 (jdbc): A execution command of JDBC task which gets your schema info and saves it to SchemaXML located to the "schema" directory. This task should be executed after ReplaceSchema task and before other tasks(e.g. Generate, Document task). manage.bat(sh) => 22 (doc): A execution command of Document task which creates documents, for example, SchemaHTML, HistoryHTML to the "output/doc" directory.
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Jul 04 22:46:31 UTC 2015 - 2.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* * This class ensures that at most one thread is running at a time. This is initially the JUnit test * thread, which yields its execution privilege while calling [runTasks], [runNextTask], or * [advanceUntil]. These functions don't return until the task threads are all idle. * * Task threads release their execution privilege in these ways: * * * By yielding in [TaskRunner.Backend.coordinatorWait]. * * By yielding in [BlockingQueue.poll].
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
if (executeImmediate) { new RunnableExecutorPair(runnable, executor).execute(); } } public void execute() { synchronized (runnables) { if (executed) { return; } executed = true; } while (!runnables.isEmpty()) { runnables.poll().execute(); } } private static class RunnableExecutorPair {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 20.5K bytes - Viewed (0) -
docs/fr/docs/tutorial/debugging.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 27 17:31:14 UTC 2024 - 2.9K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.h
} // Takes a description of a single operation being executed on the // ParallelDevice, and in turn runs one operation per component device with // its corresponding inputs from the input ParallelTensors. Wraps the // resulting per-device and per-output TFE_TensorHandles into one // ParallelTensor per output of the original operation. // // Attributes are forwarded to executed operations unmodified. //
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Mon Oct 21 04:14:14 UTC 2024 - 13.1K bytes - Viewed (0)