- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 1,134 for executors (0.42 sec)
-
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
*/ public <T extends @Nullable Object> ListenableFuture<T> submitAsync( AsyncCallable<T> callable, Executor executor) { checkNotNull(callable); checkNotNull(executor); TaskNonReentrantExecutor taskExecutor = new TaskNonReentrantExecutor(executor, this); AsyncCallable<T> task = new AsyncCallable<T>() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/junit/AbstractJUnitTestExecutionIntegrationTest.groovy
abstract TestClassExecutionResult assertFailedToExecute(TestExecutionResult testResult, String testClassName) String getStableEnvironmentDependencies() { return testFrameworkDependencies } def "executes tests in the correct environment"() { given: file('src/test/java/org/gradle/OkTest.java') << """ package org.gradle; import java.io.File; import java.io.PrintStream;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Apr 06 02:21:33 UTC 2024 - 19.6K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectAllRequestsThenReleaseAll.java
import java.util.Collection; import java.util.concurrent.Executor; import java.util.concurrent.locks.Lock; class ExpectAllRequestsThenReleaseAll extends ExpectMaxNConcurrentRequestsThenRelease { ExpectAllRequestsThenReleaseAll(Lock lock, int testId, Duration timeout, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectations, Executor executor) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNRequestsThenReleaseOne.java
import java.util.Collection; import java.util.concurrent.Executor; import java.util.concurrent.locks.Lock; public class ExpectMaxNRequestsThenReleaseOne extends ExpectMaxNConcurrentRequestsThenRelease { public ExpectMaxNRequestsThenReleaseOne(Lock lock, int testId, Duration timeout, int maxConcurrent, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectedRequests, Executor executor) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java
@Override public void connectStreams(Process process, String processName, Executor executor) { inputHandler.connectStreams(process, processName, executor); outputHandler.connectStreams(process, processName, executor); } @Override public void start() { inputHandler.start(); outputHandler.start();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 15.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/DirectExecutorService.java
} } } } /** * Checks if the executor has been shut down and increments the running task count. * * @throws RejectedExecutionException if the executor has been previously shutdown */ private void startTask() { synchronized (lock) { if (shutdown) { throw new RejectedExecutionException("Executor already shutdown"); } runningTasks++; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/cli/RunBuildAction.java
public RunBuildAction( BuildActionExecutor<BuildActionParameters, ClientBuildRequestContext> executor, StartParameterInternal startParameter, GradleLauncherMetaData clientMetaData, long startTime, BuildActionParameters buildActionParameters, ServiceRegistry sharedServices, Stoppable stoppable) { this.executor = executor; this.startParameter = startParameter; this.clientMetaData = clientMetaData;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 3.2K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/PluginServiceInjectionIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 02 18:26:28 UTC 2024 - 7.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/DefaultAsyncConsumerActionExecutor.java
private final ConsumerActionExecutor actionExecutor; private final ManagedExecutor executor; private final ServiceLifecycle lifecycle; public DefaultAsyncConsumerActionExecutor(ConsumerActionExecutor actionExecutor, ExecutorFactory executorFactory) { this.actionExecutor = actionExecutor; executor = executorFactory.create("Connection worker");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 2.8K bytes - Viewed (0)