- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 470 for executors (0.06 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
} public void testTimeout() throws Exception { // Create a service whose executor will never run its commands Service service = new TestService() { @Override protected Executor executor() { return new Executor() { @Override public void execute(Runnable command) {} }; }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 7.7K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
} public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); assertFalse(executor.isShutdown()); assertFalse(executor.isTerminated()); executor.shutdown(); assertTrue(executor.isShutdown()); assertTrue(executor.isTerminated()); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 3.3K bytes - Click Count (0) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
} public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); assertFalse(executor.isShutdown()); assertFalse(executor.isTerminated()); executor.shutdown(); assertTrue(executor.isShutdown()); assertTrue(executor.isTerminated()); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 3.3K bytes - Click Count (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* * @param listener the listener to run when the computation is complete * @param executor the executor to run the listener in * @throws RejectedExecutionException if we tried to execute the listener immediately but the * executor rejected it. */ void addListener(Runnable listener, Executor executor);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt
c1.enqueue(callback) c2.enqueue(callback) c1.cancel() executor.assertJobs("http://a/1") executor.finishJob("http://a/1") executor.assertJobs("http://a/2") } @Test fun asyncCallAccessors() { dispatcher.maxRequests = 3 val a1 = client.newCall(newRequest("http://a/1")) val a2 = client.newCall(newRequest("http://a/2"))
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 15.8K bytes - Click Count (0) -
docs/pt/docs/environment-variables.md
O sistema **encontrará** o programa `python` em `/opt/custompython/bin` e o executará. Seria aproximadamente equivalente a digitar: <div class="termy"> ```console $ /opt/custompython/bin/python ``` </div> //// //// tab | Windows O sistema **encontrará** o programa `python` em `C:\opt\custompython\bin\python` e o executará. Seria aproximadamente equivalente a digitar:
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:20:43 GMT 2026 - 8.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
*/ public <T extends @Nullable Object> ListenableFuture<T> submitAsync( AsyncCallable<T> callable, Executor executor) { checkNotNull(callable); checkNotNull(executor); TaskNonReentrantExecutor taskExecutor = new TaskNonReentrantExecutor(executor, this); AsyncCallable<T> task = new AsyncCallable<T>() { @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
// null only for TOMBSTONE final @Nullable Executor executor; // writes to next are made visible by subsequent CAS's on the listeners field @Nullable Listener next; Listener(Runnable task, Executor executor) { this.task = task; this.executor = executor; } Listener() { this.task = null; this.executor = null; } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java
assertThat(loadCount.get()).isEqualTo(1); assertThat(reloadCount.get()).isEqualTo(1); assertThat(loadAllCount.get()).isEqualTo(1); QueuingExecutor executor = new QueuingExecutor(); CacheLoader<Object, Object> asyncReloader = CacheLoader.asyncReloading(baseLoader, executor); Object unused3 = asyncReloader.load(new Object()); @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 30 22:03:28 GMT 2025 - 3.8K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/Subscriber.java
private final Method method; /** Executor to use for dispatching events to this subscriber. */ private final Executor executor; private Subscriber(EventBus bus, Object target, Method method) { this.bus = bus; this.target = checkNotNull(target); this.method = method; method.setAccessible(true); this.executor = bus.executor(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed May 14 19:40:47 GMT 2025 - 4.7K bytes - Click Count (0)