- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 887 for Callable (0.05 sec)
-
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
taskDone = false; Callable<Integer> task = new Callable<Integer>() { @Override public Integer call() { taskDone = true; return 6; } }; Future<Integer> future = TestingExecutors.sameThreadScheduledExecutor().schedule(task, 10000, MILLISECONDS); assertTrue("Should run callable immediately", taskDone);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.7K bytes - Viewed (0) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
taskDone = false; Callable<Integer> task = new Callable<Integer>() { @Override public Integer call() { taskDone = true; return 6; } }; Future<Integer> future = TestingExecutors.sameThreadScheduledExecutor().schedule(task, 10000, MILLISECONDS); assertTrue("Should run callable immediately", taskDone);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
/** * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code * Callable}. * * @param callable the callable task * @since 10.0 */ public static <V extends @Nullable Object> ListenableFutureTask<V> create(Callable<V> callable) { return new ListenableFutureTask<>(callable); } /** * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
} @ParametricNullness private <T extends @Nullable Object> T callWithTimeout( Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit, boolean amInterruptible) throws Exception { checkNotNull(callable); checkNotNull(timeoutUnit); checkPositiveTimeout(timeoutDuration); Future<T> future = executor.submit(callable); try { return amInterruptible
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 9.5K bytes - Viewed (0) -
docs/de/docs/tutorial/dependencies/classes-as-dependencies.md
Eine Python-Klasse ist also auch ein **Callable**. Darum können Sie in **FastAPI** auch eine Python-Klasse als Abhängigkeit verwenden. Was FastAPI tatsächlich prüft, ist, ob es sich um ein „Callable“ (Funktion, Klasse oder irgendetwas anderes) handelt und ob die Parameter definiert sind.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 7.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
CountDownLatch enterLatch = new CountDownLatch(1); CountDownLatch exitLatch = new CountDownLatch(1); TrustedListenableFutureTask<@Nullable Void> task = TrustedListenableFutureTask.create( new Callable<@Nullable Void>() { @Override public @Nullable Void call() throws Exception { enterLatch.countDown(); new CountDownLatch(1).await(); // wait forever
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 7.2K bytes - Viewed (0) -
docs/en/docs/tutorial/dependencies/classes-as-dependencies.md
So, a Python class is also a **callable**. Then, in **FastAPI**, you could use a Python class as a dependency. What FastAPI actually checks is that it is a "callable" (function, class or anything else) and the parameters defined.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 6.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java
*/ @Override <V extends @Nullable Object> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit); /** * Duration-based overload of {@link #schedule(Callable, long, TimeUnit)}. * * @since 29.0 */ @J2ktIncompatible default <V extends @Nullable Object> ListenableScheduledFuture<V> schedule( Callable<V> callable, Duration delay) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Feb 11 17:30:04 UTC 2025 - 3.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
List<Callable<T>> tasks = ImmutableList.of(); List<? extends Future<?>> unused = executor.invokeAll(tasks); } public void testListeningDecorator() throws Exception { ListeningExecutorService service = listeningDecorator(newDirectExecutorService()); assertSame(service, listeningDecorator(service)); List<Callable<String>> callables = ImmutableList.of(Callables.returning("x"));
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 28K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FakeTimeLimiterTest.java
runnableThrowing(exception), DELAY_MS, MILLISECONDS)); assertThat(e).hasCauseThat().isEqualTo(exception); } public static <T> Callable<T> callableThrowing(Exception exception) { return new Callable<T>() { @Override public T call() throws Exception { throw exception; } }; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 4.1K bytes - Viewed (0)