- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,912 for executors (1.37 sec)
-
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertFalse(future.isCancelled()); ExecutorService executor = Executors.newSingleThreadExecutor(); try { Future<Boolean> getResult = executor.submit(() -> future.get()); // Release the future value. latch.countDown(); assertTrue(getResult.get(10, SECONDS)); } finally { executor.shutdownNow(); } assertTrue(future.isDone());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/impl/DefaultGradleEnterprisePluginBackgroundJobExecutors.java
})); } @Override public boolean isInBackground() { return Thread.currentThread() instanceof BackgroundThread; } /** * Shuts the executors down. * All executors immediately stops accepting new jobs. The method blocks until already submitted jobs complete. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 29 16:27:53 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/DefaultExecutorServiceFactory.java
*/ package org.gradle.tooling.internal.consumer; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class DefaultExecutorServiceFactory implements ExecutorServiceFactory { @Override public ExecutorService create() { return Executors.newSingleThreadExecutor(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 940 bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/GradleEnterprisePluginBackgroundJobExecutors.java
import java.util.concurrent.Executor; import java.util.concurrent.RejectedExecutionException; /** * Provides executors to run jobs in the background workers. The implementation is provided by Gradle. */ @ServiceScope(Scope.BuildTree.class) public interface GradleEnterprisePluginBackgroundJobExecutors { /** * Returns the executor to run user-provided background jobs in the background workers.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
*/ public static <V extends @Nullable Object> ListenableFuture<V> listenInPoolThread( Future<V> future, Executor executor) { checkNotNull(executor); if (future instanceof ListenableFuture) { return (ListenableFuture<V>) future; } return new ListenableFutureAdapter<>(future, executor); } /** * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
platforms/core-execution/snapshots/src/test/groovy/org/gradle/internal/vfs/impl/DefaultFileSystemAccessConcurrencyTest.groovy
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.vfs.impl import java.util.concurrent.Executors import java.util.concurrent.TimeUnit class DefaultFileSystemAccessConcurrencyTest extends AbstractFileSystemAccessTest { def "parallel invalidation yields correct results"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:34:50 UTC 2023 - 1.8K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3.2K bytes - Viewed (0) -
platforms/jvm/jvm-services/src/integTest/groovy/org/gradle/internal/jvm/inspection/DefaultJvmMetadataDetectorIntegrationTest.groovy
import org.gradle.process.internal.DefaultExecHandleBuilder import org.gradle.test.precondition.Requires import org.gradle.test.preconditions.IntegTestPreconditions import java.util.concurrent.Executors class DefaultJvmMetadataDetectorIntegrationTest extends AbstractIntegrationSpec { @Requires(IntegTestPreconditions.JavaHomeWithDifferentVersionAvailable) def "works on real installation"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 18:25:34 UTC 2024 - 2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationQueueTest.groovy
} } def executor = Mock(Executor) def delegateExecutor = Executors.newFixedThreadPool(threads) operationQueue = new DefaultBuildOperationQueue(false, workerRegistry, executor, new SimpleWorker()) println "expecting ${expectedWorkerCount} concurrent work processors to be started..." when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * @param executor The executor to decorate * @param nameSupplier The source of names for each task */ @J2ktIncompatible @GwtIncompatible // concurrency static Executor renamingDecorator(final Executor executor, final Supplier<String> nameSupplier) { checkNotNull(executor); checkNotNull(nameSupplier); return new Executor() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 39K bytes - Viewed (0)