Home
last modified time | relevance | path

Searched refs:numberOfThreads (Results 1 – 6 of 6) sorted by relevance

/external/guava/guava-testlib/test/com/google/common/testing/
DFakeTickerTest.java108 int numberOfThreads = 64; in testConcurrentAdvance() local
109 runConcurrentTest(numberOfThreads, in testConcurrentAdvance()
121 assertEquals(numberOfThreads * 2, ticker.read()); in testConcurrentAdvance()
131 int numberOfThreads = 64; in testConcurrentAutoIncrementStep() local
132 runConcurrentTest(numberOfThreads, in testConcurrentAutoIncrementStep()
141 assertEquals(incrementByNanos * numberOfThreads, ticker.read()); in testConcurrentAutoIncrementStep()
148 private void runConcurrentTest(int numberOfThreads, final Callable<Void> callable) in runConcurrentTest() argument
150 ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads); in runConcurrentTest()
151 final CountDownLatch startLatch = new CountDownLatch(numberOfThreads); in runConcurrentTest()
152 final CountDownLatch doneLatch = new CountDownLatch(numberOfThreads); in runConcurrentTest()
[all …]
/external/r8/src/main/java/com/android/tools/r8/utils/
DThreadUtils.java37 if (options.numberOfThreads == options.NOT_SPECIFIED) { in getExecutorService()
41 } else if (options.numberOfThreads == 1) { in getExecutorService()
44 return Executors.newWorkStealingPool(options.numberOfThreads); in getExecutorService()
DInternalOptions.java42 public int numberOfThreads = NOT_SPECIFIED; field in InternalOptions
/external/mockito/src/test/java/org/concurrentmockito/
DThreadsRunAllTestsHalfManualTest.java150 public static Set<Class<?>> runInMultipleThreads(int numberOfThreads) throws Exception { in runInMultipleThreads() argument
152 for (int i = 1; i <= numberOfThreads; i++) { in runInMultipleThreads()
170 int numberOfThreads = 20; in main() local
172 Set<Class<?>> failed = runInMultipleThreads(numberOfThreads); in main()
175 …System.out.println("Finished tests in " + numberOfThreads + " threads in " + executionTime + " sec… in main()
/external/r8/src/main/java/com/android/tools/r8/compatdx/
DCompatDx.java344 int numberOfThreads = 1; in run() local
426 numberOfThreads = dexArgs.numThreads; in run()
447 if (numberOfThreads < 1) { in run()
448 throw new DxUsageMessage("Invalid numThreads value of " + numberOfThreads); in run()
450 ExecutorService executor = ThreadUtils.getExecutorService(numberOfThreads); in run()
/external/r8/src/test/java/com/android/tools/r8/internal/
DR8GMSCoreDeterministicTest.java45 options.numberOfThreads = 1; in doRun()