- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 24 for futureTasks (0.2 sec)
-
platforms/enterprise/enterprise/src/test/groovy/org/gradle/internal/enterprise/impl/DefaultGradleEnterprisePluginBackgroundJobExecutorsTest.groovy
* limitations under the License. */ package org.gradle.internal.enterprise.impl import org.gradle.internal.cc.impl.InputTrackingState import spock.lang.Specification import java.util.concurrent.FutureTask import java.util.concurrent.RejectedExecutionException class DefaultGradleEnterprisePluginBackgroundJobExecutorsTest extends Specification { DefaultGradleEnterprisePluginBackgroundJobExecutors jobExecutors
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/AbstractConditionalExecution.java
import org.gradle.internal.UncheckedException; import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; import java.util.concurrent.RunnableFuture; public abstract class AbstractConditionalExecution<T> implements ConditionalExecution<T> { private final CountDownLatch finished = new CountDownLatch(1);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
final Runnable runChosenTest = new Runnable() { @Override public void run() { runChosenTest(); } }; final FutureTask<@Nullable Void> task = new FutureTask<>(runChosenTest, null); startThread( new Runnable() { @Override public void run() { task.run(); } });
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 27.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
final Runnable runChosenTest = new Runnable() { @Override public void run() { runChosenTest(); } }; final FutureTask<@Nullable Void> task = new FutureTask<>(runChosenTest, null); startThread( new Runnable() { @Override public void run() { task.run(); } });
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 25.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService) * MoreExecutors.listeningDecorator}. * <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method, * create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer * {@link AbstractFuture}.) * </ul> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService) * MoreExecutors.listeningDecorator}. * <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method, * create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer * {@link AbstractFuture}.) * </ul> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService) * MoreExecutors.listeningDecorator}. * <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method, * create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer * {@link AbstractFuture}.) * </ul> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
* Any of the setException() calls below can fail if the output Future is cancelled between now * and then. This means that we're silently swallowing an exception -- maybe even an Error. But * this is no worse than what FutureTask does in that situation. Additionally, because the * Future was cancelled, its listeners have been run, so its consumers will not hang. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
* Any of the setException() calls below can fail if the output Future is cancelled between now * and then. This means that we're silently swallowing an exception -- maybe even an Error. But * this is no worse than what FutureTask does in that situation. Additionally, because the * Future was cancelled, its listeners have been run, so its consumers will not hang. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* Future might not even be a ListenableFuture, just a plain Future. That said, similar * problems can exist with methods like FutureTask.done(), not to mention slow calls to * Thread.interrupt() (as discussed in InterruptibleTask). At the end of the day, it's * unlikely that cancel() will be slow, so we can probably get away with calling it while
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 25.8K bytes - Viewed (0)