- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,209 for executors (0.59 sec)
-
platforms/core-runtime/wrapper-main/src/crossVersionTest/groovy/org/gradle/integtests/wrapper/WrapperOldJavaCrossVersionIntegrationTest.groovy
when: GradleExecuter executor = prepareWrapperExecuter(previous, current).withJavaHome(jdk.javaHome) then: def result = executor.usingExecutable('gradlew').withArgument('help').runWithFailure()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:54:32 UTC 2024 - 2.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
*/ protected void triggerShutdown() {} /** * Returns the {@link Executor} that will be used to run this service. Subclasses may override * this method to use a custom {@link Executor}, which may configure its worker thread with a * specific name, thread group or priority. The returned executor's {@link * Executor#execute(Runnable) execute()} method is called when this service is started, and should
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 7.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/testFixtures/groovy/org/gradle/containers/GradleContainerExecuter.groovy
import org.gradle.integtests.fixtures.executer.AbstractGradleExecuter import org.gradle.integtests.fixtures.executer.ExecutionFailure import org.gradle.integtests.fixtures.executer.ExecutionResult import org.gradle.integtests.fixtures.executer.GradleDistribution import org.gradle.integtests.fixtures.executer.OutputScrapingExecutionFailure import org.gradle.integtests.fixtures.executer.OutputScrapingExecutionResult
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 3K bytes - Viewed (0) -
testing/internal-testing/src/test/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpecTest.groovy
then: instant.thing == operation.thing.end } static class Worker { final Executor executor final Object lock = new Object() int count Worker(Executor executor) { this.executor = executor } void run(Runnable runnable, int timeoutSeconds) { def finished = new CountDownLatch(1)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 8.7K bytes - Viewed (0) -
build-logic/integration-testing/src/main/kotlin/gradlebuild.cross-version-tests.gradle.kts
fun createQuickFeedbackTasks() { val testType = TestType.CROSSVERSION val defaultExecuter = "embedded" val prefix = testType.prefix testType.executers.forEach { executer -> val taskName = "$executer${prefix.capitalize()}Test" val testTask = createTestTask(taskName, executer, sourceSet, testType) { this.setSystemPropertiesOfTestJVM("latest") this.systemProperties["org.gradle.integtest.crossVersion"] = "true"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 06:17:20 UTC 2024 - 4.5K bytes - Viewed (0) -
platforms/documentation/docs/src/docsTest/java/org/gradle/docs/samples/IntegrationTestSamplesExecutor.java
import org.gradle.exemplar.executor.CommandExecutor; import org.gradle.integtests.fixtures.AvailableJavaHomes; import org.gradle.integtests.fixtures.executer.ExecutionFailure; import org.gradle.integtests.fixtures.executer.ExecutionResult; import org.gradle.integtests.fixtures.executer.GradleContextualExecuter; import org.gradle.integtests.fixtures.executer.GradleDistribution;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 6.6K bytes - Viewed (0) -
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) -
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)