- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 2,328 for executors (0.16 sec)
-
subprojects/core/src/main/java/org/gradle/execution/plan/PlanExecutor.java
@ThreadSafe public interface PlanExecutor { /** * Executes a {@link WorkSource}, blocking until complete. * * @param workSource the work to execute. * @param worker the actual executor responsible to execute the nodes. Must be thread-safe. */ <T> ExecutionResult<Void> process(WorkSource<T> workSource, Action<T> worker); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/cli/BuildActionsFactoryTest.groovy
void isDaemon(def action) { def runnable = unwrapAction(action) def executor = unwrapExecutor(runnable) assert executor instanceof DaemonClient } void isInProcess(def action) { def runnable = unwrapAction(action) def executor = unwrapExecutor(runnable) assert executor instanceof RunInProcess } void isSingleUseDaemon(def action) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 05:33:15 UTC 2024 - 7.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/internal/resolve/caching/CrossBuildCachingRuleExecutorTest.groovy
) } def "doesn't do anything if rule is null"() { def id = new Id('Alicia') when: executor.execute(id, null, detailsToResult, onCacheMiss, cachePolicy) then: 0 * _ } def "executes the rule without caching if the rule is not cacheable"() { withNonCacheableToUpperCaseRule() def id = new Id('Alicia') when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jan 10 15:51:31 UTC 2024 - 11.9K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultPlanExecutorTest.groovy
def workerLeaseService = Mock(WorkerLeaseService) def workerLease = Mock(WorkerLeaseRegistry.WorkerLease) def executor = new DefaultPlanExecutor(new DefaultWorkerLimits(1), executorFactory, workerLeaseService, cancellationHandler, coordinationService, new DefaultInternalOptions([:])) def "executes tasks until no further tasks remain"() { def gradle = Mock(Gradle) def project = Mock(Project)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/core-execution/execution-e2e-tests/src/integTest/groovy/org/gradle/integtests/ParallelProjectExecutionIntegrationTest.groovy
} } } } } """ executer.withArgument('--parallel') executer.withArgument('--max-workers=3') // needs to be set to the maximum number of expectConcurrentExecution() calls executer.withArgument('--info') } def "executes dependency project targets concurrently"() { projectDependency from: 'a', to: ['b', 'c', 'd']
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 04 10:15:40 UTC 2024 - 4.9K bytes - Viewed (0) -
platforms/documentation/docs/src/docsTest/java/org/gradle/docs/samples/IntegrationTestSamplesRunner.java
* limitations under the License. */ package org.gradle.docs.samples; import org.gradle.api.GradleException; import org.gradle.exemplar.executor.CommandExecutor; import org.gradle.exemplar.executor.ExecutionMetadata; import org.gradle.exemplar.model.Command; import org.gradle.exemplar.model.Sample; import org.gradle.exemplar.test.runner.SamplesRunner;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 29 22:10:58 UTC 2023 - 3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* calling thread. Tasks are run to completion before a {@code Future} is returned to the caller * (unless the executor has been shutdown). * * <p>The returned executor is backed by the executor returned by {@link * MoreExecutors#newDirectExecutorService} and subject to the same constraints. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 17:12:37 UTC 2024 - 6.6K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
private final SyncPoint syncPoint = new SyncPoint(); /** * Creates an Executor which the test can control. */ protected ExecutorService getExecutor() { if (executor == null) { executor = new ExecutorImpl(); } return executor; } /** * Creates an ExecutorFactory for the test to use. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
DefaultBuildOperationQueue(boolean allowAccessToProjectState, WorkerLeaseService workerLeases, Executor executor, QueueWorker<T> queueWorker) { this.allowAccessToProjectState = allowAccessToProjectState; this.workerLeases = workerLeases; this.executor = executor; this.queueWorker = queueWorker; } @Override public void add(final T operation) { lock.lock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0) -
platforms/ide/ide-native/src/integTest/groovy/org/gradle/ide/visualstudio/fixtures/AbstractVisualStudioIntegrationSpec.groovy
// Gradle needs to be isolated so that msbuild does not leave behind daemons assert executer.distribution.gradleHomeDir != null assert !executer.usesSharedDaemons() def executer = new MSBuildExecutor(testDirectory, toolChain) executer.withArgument('/p:Platform=Win32') return executer } protected SolutionFile solutionFile(String path) { return solutionFile(file(path))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:12 UTC 2023 - 5.4K bytes - Viewed (0)