- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for RunAll (0.14 sec)
-
subprojects/core/src/testFixtures/groovy/org/gradle/internal/operations/TestBuildOperationExecutor.java
runAll(schedulingAction); } @Override public <O extends BuildOperation> void runAll(BuildOperationWorker<O> worker, Action<BuildOperationQueue<O>> schedulingAction) { runAll(worker, schedulingAction, BuildOperationConstraint.MAX_WORKERS); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 12:12:49 UTC 2024 - 3.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/operations/BuildOperationExecutor.java
*/ <O extends BuildOperation> void runAll(BuildOperationWorker<O> worker, Action<BuildOperationQueue<O>> schedulingAction); /** * Overload allowing {@link BuildOperationConstraint} to be specified. * * @see BuildOperationExecutor#runAll(BuildOperationWorker, Action) */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 3.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationExecutor.java
} @Override public <O extends RunnableBuildOperation> void runAll(Action<BuildOperationQueue<O>> schedulingAction) { runAll(schedulingAction, BuildOperationConstraint.MAX_WORKERS); } @Override public <O extends RunnableBuildOperation> void runAll(Action<BuildOperationQueue<O>> schedulingAction, BuildOperationConstraint buildOperationConstraint) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 7K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationExecutorParallelExecutionTest.groovy
buildOperationExecutor.runAll(worker, { queue -> amountOfWork.times { queue.add(success) } }) successfulQueueCompleted = true } // Failure queue workerThread { try { buildOperationExecutor.runAll(worker, { queue ->
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.6K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/MaxWorkersTest.groovy
thread.blockUntil.worker1 instant.worker2Ready ConcurrentSpec spec = this; def child2 = workerLeaseService.startWorker() processor.runAll(processorWorker, { queue -> queue.add(new DefaultBuildOperationQueueTest.TestBuildOperation() { @Override void run(BuildOperationContext buildOperationContext) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 8.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/CrawlJob.java
} } final StringBuilder resultBuf = new StringBuilder(100); final boolean runAll = webConfigIds == null && fileConfigIds == null && dataConfigIds == null; if (sessionId == null) { // create session id final SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java
public void crawl(final String sessionId, final List<String> webConfigIdList, final List<String> fileConfigIdList) { final boolean runAll = webConfigIdList == null && fileConfigIdList == null; final List<WebConfig> webConfigList; if (runAll || webConfigIdList != null) { webConfigList = ComponentUtil.getCrawlingConfigHelper().getWebConfigListByIds(webConfigIdList); } else {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 22.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
final List<String> dataConfigIdList = options.getDataConfigIdList(); final boolean runAll = webConfigIdList == null && fileConfigIdList == null && dataConfigIdList == null; Thread webFsCrawlerThread = null; Thread dataCrawlerThread = null; if (runAll || webConfigIdList != null || fileConfigIdList != null) { webFsCrawlerThread = new Thread((Runnable) () -> {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 24.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/integTest/groovy/org/gradle/internal/operations/BuildOperationExecutorIntegrationTest.groovy
task causeErrors { doLast { def buildOperationExecutor = services.get(BuildOperationExecutor) buildOperationExecutor.runAll { queue -> queue.add(new TestOperation(startedLatch)) queue.add(new TestOperation(startedLatch)) startedLatch.await()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 12:12:49 UTC 2024 - 5.4K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/junit/result/Binary2JUnitXmlReportGenerator.java
public BuildOperationDescriptor.Builder description() { return BuildOperationDescriptor.displayName("Delete old JUnit XML results"); } }); buildOperationExecutor.runAll(new Action<BuildOperationQueue<JUnitXmlReportFileGenerator>>() { @Override public void execute(final BuildOperationQueue<JUnitXmlReportFileGenerator> queue) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 12:54:04 UTC 2024 - 5.5K bytes - Viewed (0)