- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 490 for callableId (0.18 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java
*/ @CanIgnoreReturnValue // TODO(kak): consider removing this @Override protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor(Callable<T> callable) { return TrustedListenableFutureTask.create(callable); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public ListenableFuture<?> submit(Runnable task) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java
*/ @CanIgnoreReturnValue // TODO(kak): consider removing this @Override protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor(Callable<T> callable) { return TrustedListenableFutureTask.create(callable); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public ListenableFuture<?> submit(Runnable task) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 3K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ManagedScheduledExecutorImpl.java
return delegate.schedule(trackedCommand(command), delay, unit); } @Override public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { return delegate.schedule(trackedCommand(callable), delay, unit); } @Override public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java
import java.util.Set; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import junit.framework.TestCase; public final class ListeningExecutorServiceTest extends TestCase { private Collection<? extends Callable<?>> recordedTasks; private long recordedTimeout;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 02 12:45:23 UTC 2023 - 4.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/AbstractConditionalExecution.java
private final CountDownLatch finished = new CountDownLatch(1); private final RunnableFuture<T> runnable; public AbstractConditionalExecution(final Callable<T> callable) { this.runnable = new FutureTask<T>(callable); } @Override public Runnable getExecution() { return runnable; } @Override public T await() { boolean interrupted = false;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.2K 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(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
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) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/util/internal/DeferredUtil.java
return value instanceof Callable || isKotlinFunction0Deferrable(value); } @Nullable public static Object unpackNestableDeferred(@Nullable Object deferred) { Object current = deferred; while (isNestableDeferred(current)) { if (current instanceof Callable) { current = uncheckedCall((Callable<?>) current); } else {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 12:20:43 UTC 2024 - 3.4K bytes - Viewed (0) -
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(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java
final Callable<Integer> testCallable = new Callable<Integer>() { public Integer call() throws Exception { CrawlingParameterUtil.setUrlQueue(q); controller.delayBeforeProcessing(); return 0; } }; // Callableタスクを複数生成 final List<Callable<Integer>> tasks = new ArrayList<Callable<Integer>>();
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3.2K bytes - Viewed (0)