- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 159 for Callables (0.3 seconds)
-
android/guava/src/com/google/common/util/concurrent/Callables.java
Callable<T> callable, ListeningExecutorService listeningExecutorService) { checkNotNull(callable); checkNotNull(listeningExecutorService); return () -> listeningExecutorService.submit(callable); } /** * Wraps the given callable such that for the duration of {@link Callable#call} the thread that is * running will have the given name. * * @param callable The callable to wrapCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 4.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
}; results.add(serializer.submit(Callables.returning(null), manualExecutor)); Future<?>[] thingToCancel = new Future<?>[1]; results.add( serializer.submit( () -> { thingToCancel[0].cancel(false); return null; }, directExecutor())); thingToCancel[0] = serializer.submit(Callables.returning(null), directExecutor());Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public void testReturning() throws Exception { assertThat(Callables.returning(null).call()).isNull(); Object value = new Object(); Callable<Object> callable = Callables.returning(value); assertThat(callable.call()).isEqualTo(value); // Expect the same value on subsequent calls assertThat(callable.call()).isEqualTo(value); } @J2ktIncompatible @GwtIncompatible
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public void testReturning() throws Exception { assertThat(Callables.returning(null).call()).isNull(); Object value = new Object(); Callable<Object> callable = Callables.returning(value); assertThat(callable.call()).isEqualTo(value); // Expect the same value on subsequent calls assertThat(callable.call()).isEqualTo(value); } @J2ktIncompatible @GwtIncompatible
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
} } private static List<Callable<String>> createTasks(int n) { List<Callable<String>> callables = new ArrayList<>(); for (int i = 0; i < n; i++) { callables.add(Callables.returning(RESULT_VALUE + i)); } return callables; } private static final class WrappedCallable<T> implements Callable<T> { private final Callable<T> delegate;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
} } private static List<Callable<String>> createTasks(int n) { List<Callable<String>> callables = new ArrayList<>(); for (int i = 0; i < n; i++) { callables.add(Callables.returning(RESULT_VALUE + i)); } return callables; } private static final class WrappedCallable<T> implements Callable<T> { private final Callable<T> delegate;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
}; results.add(serializer.submit(Callables.returning(null), manualExecutor)); Future<?>[] thingToCancel = new Future<?>[1]; results.add( serializer.submit( () -> { thingToCancel[0].cancel(false); return null; }, directExecutor())); thingToCancel[0] = serializer.submit(Callables.returning(null), directExecutor());Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (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()); assertThat(listeningDecorator(service)).isSameInstanceAs(service); List<Callable<String>> callables = ImmutableList.of(Callables.returning("x"));
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.1K bytes - Click Count (0) -
android/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()); assertThat(listeningDecorator(service)).isSameInstanceAs(service); List<Callable<String>> callables = ImmutableList.of(Callables.returning("x"));
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.1K bytes - Click Count (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.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Wed Feb 11 18:32:12 GMT 2026 - 6.8K bytes - Click Count (0)