- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 470 for executors (0.13 seconds)
-
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
import static com.google.common.util.concurrent.MoreExecutors.listeningDecorator; import static java.lang.Math.max; import static java.lang.Thread.State.WAITING; import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.MINUTES; import static java.util.concurrent.TimeUnit.NANOSECONDS;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 114.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
import static com.google.common.util.concurrent.MoreExecutors.listeningDecorator; import static java.lang.Math.max; import static java.lang.Thread.State.WAITING; import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.MINUTES; import static java.util.concurrent.TimeUnit.NANOSECONDS;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 116.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/JobExecutorTest.java
// Test multiple JobExecutor instances JobExecutor executor1 = new TestJobExecutor(); JobExecutor executor2 = new TestJobExecutor(); AtomicInteger counter1 = new AtomicInteger(0); AtomicInteger counter2 = new AtomicInteger(0); executor1.addShutdownListener(() -> counter1.incrementAndGet()); executor2.addShutdownListener(() -> counter2.incrementAndGet());Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 9.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java
protected abstract void shutDown() throws Exception; /** * Returns the {@link Executor} that will be used to run this service. Subclasses may override * this method to use a custom {@link Executor}, which may configure its worker thread with a * specific name, thread group or priority. The returned executor's {@link * Executor#execute(Runnable) execute()} method is called when this service is started and
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 5.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
*/ protected void triggerShutdown() {} /** * Returns the {@link Executor} that will be used to run this service. Subclasses may override * this method to use a custom {@link Executor}, which may configure its worker thread with a * specific name, thread group or priority. The returned executor's {@link * Executor#execute(Runnable) execute()} method is called when this service is started, and should
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 7.2K bytes - Click Count (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* calling thread. Tasks are run to completion before a {@code Future} is returned to the caller * (unless the executor has been shutdown). * * <p>The returned executor is backed by the executor returned by {@link * MoreExecutors#newDirectExecutorService} and subject to the same constraints. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 6.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
*/ protected abstract String getExecuteType(); /** * Executes the job with the specified job executor. * This method sets the job executor and then calls the abstract execute method. * * @param jobExecutor the job executor to use for execution * @return the execution result message or summary */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 14.2K bytes - Click Count (0) -
build-tools-internal/src/integTest/groovy/org/elasticsearch/gradle/internal/test/rerun/InternalTestRerunPluginFuncTest.groovy
def result = gradleRunner("test").build() result.output.contains("AnotherTest6 total executions: 2") // triggered only in the second overall run and: 'Tracing is provided' result.output.contains("""================ Test jvm exited unexpectedly. Test jvm system exit trace (run: 1) Gradle Test Executor 1 > AnotherTest6 > someTest ================""") }
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Fri Sep 03 10:22:28 GMT 2021 - 8.9K bytes - Click Count (0) -
docs/fr/docs/tutorial/background-tasks.md
**FastAPI** créera l'objet de type `BackgroundTasks` pour vous et le passera comme paramètre. ## Créer une fonction de tâche { #create-a-task-function } Créez une fonction à exécuter comme tâche d'arrière-plan. Une fonction à exécuter comme tâche d'arrière-plan est juste une fonction standard qui peut recevoir des paramètres.Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 5.5K bytes - Click Count (0) -
docs/fr/docs/advanced/events.md
Vous pouvez probablement passer cette partie. /// Il existe une autre manière de définir cette logique à exécuter au *démarrage* et à l'*arrêt*. Vous pouvez définir des gestionnaires d'événements (fonctions) qui doivent être exécutés avant le démarrage de l'application, ou lorsque l'application s'arrête. Ces fonctions peuvent être déclarées avec `async def` ou un `def` normal.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 9.1K bytes - Click Count (0)