- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for NumThreads (0.15 sec)
-
platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/report/DefaultTestReportTest.groovy
where: numThreads << [1, 4] } def "generates report with aggregated index page for failing build - #numThreads parallel thread(s)"() { given: report = reportWithMaxThreads(numThreads) def testTestResults = failingBuildResults() when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 27.2K bytes - Viewed (0) -
platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/junit/result/Binary2JUnitXmlReportGeneratorSpec.groovy
BuildOperationExecutor buildOperationExecutor Binary2JUnitXmlReportGenerator generator def generatorWithMaxThreads(int numThreads) { buildOperationExecutor = BuildOperationExecutorSupport.builder(numThreads) .withRunner(buildOperationRunner) .build() Binary2JUnitXmlReportGenerator reportGenerator = new Binary2JUnitXmlReportGenerator(
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 25 19:07:01 UTC 2024 - 3.6K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/internal/operations/BuildOperationExecutorSupport.java
import org.gradle.internal.work.WorkerLeaseService; import org.gradle.test.fixtures.work.TestWorkerLeaseService; public class BuildOperationExecutorSupport { public static Builder builder(int numThreads) { return builder(new DefaultWorkerLimits(numThreads)); } public static Builder builder(WorkerLimits workerLimits) { return new Builder(workerLimits); } public static class Builder {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 4.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} @J2ktIncompatible @GwtIncompatible // blocking wait public void testRunIdempotency() throws Exception { final int numThreads = 10; final ExecutorService executor = Executors.newFixedThreadPool(numThreads); for (int i = 0; i < 1000; i++) { final AtomicInteger counter = new AtomicInteger(); final TrustedListenableFutureTask<Integer> task =
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 7.3K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/DefaultSerializerRegistrySpec.groovy
def "invoking DefaultSerializerRegistry from multiple threads"() { given: def conditions = new AsyncConditions(numThreads) def serializer = Stub(Serializer) numThreads.times { threadId -> Thread.startDaemon("DefaultSerializerRegistry Test #$threadId") { conditions.evaluate {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 10.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} @J2ktIncompatible @GwtIncompatible // blocking wait public void testRunIdempotency() throws Exception { final int numThreads = 10; final ExecutorService executor = Executors.newFixedThreadPool(numThreads); for (int i = 0; i < 1000; i++) { final AtomicInteger counter = new AtomicInteger(); final TrustedListenableFutureTask<Integer> task =
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 7.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/BloomFilterTest.java
List<Throwable> exceptions = runThreadsAndReturnExceptions(numThreads, task); assertThat(exceptions).isEmpty(); } private static List<Throwable> runThreadsAndReturnExceptions(int numThreads, Runnable task) { List<Thread> threads = new ArrayList<>(numThreads); final List<Throwable> exceptions = new ArrayList<>(numThreads); for (int i = 0; i < numThreads; i++) { Thread thread = new Thread(task);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 15:27:58 UTC 2024 - 21.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
if (executorService == null) { int numThreads = ComponentUtil.getFessConfig().getRankFusionThreadsAsInteger(); if (numThreads <= 0) { numThreads = (Runtime.getRuntime().availableProcessors() * 3) / 2 + 1; } executorService = Executors.newFixedThreadPool(numThreads); } } }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/runtime_fallback/runtime_fallback_executor.cc
std::max(1, static_cast<int32_t>(num_threads))) {} void Schedule(std::function<void()> fn) override { tpool_.Schedule(std::move(fn)); } int NumThreads() const override { return tpool_.NumThreads(); } int CurrentThreadId() const override { return tpool_.CurrentThreadId(); } void Cancel() override {} private: ThreadPool tpool_; }; } // namespace
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 08 00:18:59 UTC 2024 - 9.1K bytes - Viewed (0)