- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 196 for callables (0.19 sec)
-
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
} @WeakOuter private final class TrustedFutureInterruptibleTask extends InterruptibleTask<V> { private final Callable<V> callable; TrustedFutureInterruptibleTask(Callable<V> callable) { this.callable = checkNotNull(callable); } @Override final boolean isDone() { return TrustedListenableFutureTask.this.isDone(); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 5.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
private static final String GOOD_CALLABLE_RESULT = "good callable result"; private static final Callable<String> GOOD_CALLABLE = new Callable<String>() { @Override public String call() throws InterruptedException { MILLISECONDS.sleep(DELAY_MS); return GOOD_CALLABLE_RESULT; } }; private static final Callable<String> BAD_CALLABLE = new Callable<String>() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
tests/test_callable_endpoint.py
Sebastián RamÃrez <******@****.***> 1593368010 +0200
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sun Jun 28 18:13:30 GMT 2020 - 457 bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* <p>Cancellation does not propagate from the output future to a callable that has begun to * execute, but if the output future is cancelled before {@link Callable#call()} is invoked, * {@link Callable#call()} will not be invoked. */ public <T extends @Nullable Object> ListenableFuture<T> submit( Callable<T> callable, Executor executor) { checkNotNull(callable); checkNotNull(executor); return submitAsync(
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
private final Callable<V> callable; CallableInterruptibleTask(Callable<V> callable, Executor listenerExecutor) { super(listenerExecutor); this.callable = checkNotNull(callable); } @Override @ParametricNullness V runInterruptibly() throws Exception { return callable.call(); } @Override void setValue(@ParametricNullness V value) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
* @throws ExecutionException if {@code callable} throws a checked exception * @throws UncheckedExecutionException if {@code callable} throws a {@code RuntimeException} * @throws ExecutionError if {@code callable} throws an {@code Error} * @since 22.0 */ @CanIgnoreReturnValue @ParametricNullness <T extends @Nullable Object> T callUninterruptiblyWithTimeout( Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit)
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 8.3K bytes - Viewed (0) -
android/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
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jun 27 14:21:11 GMT 2023 - 9.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
} @Override public <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks) throws InterruptedException { return delegate().invokeAll(tasks); } @Override public <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
return schedule(java.util.concurrent.Executors.callable(command), delay, unit); } @Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) { Preconditions.checkNotNull(callable, "callable must not be null!"); Preconditions.checkNotNull(unit, "unit must not be null!"); ListenableFuture<V> delegateFuture = submit(callable);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Oct 06 00:47:57 GMT 2021 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
@Override @ParametricNullness public <T extends @Nullable Object> T callWithTimeout( Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) throws ExecutionException { checkNotNull(callable); checkNotNull(timeoutUnit); try { return callable.call(); } catch (RuntimeException e) { throw new UncheckedExecutionException(e); } catch (Exception e) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 3.5K bytes - Viewed (0)