| /external/guava/android/guava-testlib/test/com/google/common/testing/ |
| D | FakeTickerTest.java | 108 int numberOfThreads = 64; in testConcurrentAdvance() local
110 numberOfThreads, in testConcurrentAdvance()
122 assertEquals(numberOfThreads * 2, ticker.read()); in testConcurrentAdvance()
132 int numberOfThreads = 64; in testConcurrentAutoIncrementStep() local
134 numberOfThreads, in testConcurrentAutoIncrementStep()
143 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/guava/guava-testlib/test/com/google/common/testing/ |
| D | FakeTickerTest.java | 119 int numberOfThreads = 64; in testConcurrentAdvance() local
121 numberOfThreads, in testConcurrentAdvance()
133 assertEquals(numberOfThreads * 2, ticker.read()); in testConcurrentAdvance()
143 int numberOfThreads = 64; in testConcurrentAutoIncrementStep() local
145 numberOfThreads, in testConcurrentAutoIncrementStep()
154 assertEquals(incrementByNanos * numberOfThreads, ticker.read()); in testConcurrentAutoIncrementStep()
159 private void runConcurrentTest(int numberOfThreads, final Callable<Void> callable) in runConcurrentTest() argument
161 ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads); in runConcurrentTest()
162 final CountDownLatch startLatch = new CountDownLatch(numberOfThreads); in runConcurrentTest()
163 final CountDownLatch doneLatch = new CountDownLatch(numberOfThreads); in runConcurrentTest()
[all …]
|
| /external/tensorflow/tensorflow/lite/objc/tests/ |
| D | TFLInterpreterOptionsTests.m | 34 XCTAssertEqual(options.numberOfThreads, 0);
40 options.numberOfThreads = 2;
41 XCTAssertEqual(options.numberOfThreads, 2);
42 options.numberOfThreads = 0;
43 XCTAssertEqual(options.numberOfThreads, 0);
44 options.numberOfThreads = 3;
45 XCTAssertEqual(options.numberOfThreads, 3);
|
| D | TFLInterpreterTests.m | 104 options.numberOfThreads = 2;
188 options.numberOfThreads = 2;
|
| /external/mockito/src/test/java/org/concurrentmockito/ |
| D | ThreadsRunAllTestsHalfManualTest.java | 151 public static Set<Class<?>> runInMultipleThreads(int numberOfThreads) throws Exception { in runInMultipleThreads() argument
153 for (int i = 1; i <= numberOfThreads; i++) { in runInMultipleThreads()
171 int numberOfThreads = 20; in main() local
173 Set<Class<?>> failed = runInMultipleThreads(numberOfThreads); in main()
176 …System.out.println("Finished tests in " + numberOfThreads + " threads in " + executionTime + " sec… in main()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ExecutorRule.kt | 13 class ExecutorRule(private val numberOfThreads: Int) : TestRule, ExecutorCoroutineDispatcher() { constant in kotlinx.coroutines.ExecutorRule
23 _executor = newFixedThreadPoolContext(numberOfThreads, threadPrefix) in apply()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | LeakedExceptionTest.kt | 98 private fun withFixedThreadPool(numberOfThreads: Int, block: (CoroutineDispatcher) -> Unit) { in <lambda>()
99 val pool = Executors.newFixedThreadPool(numberOfThreads) in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | LeakedExceptionTest.kt | 98 private fun withFixedThreadPool(numberOfThreads: Int, block: (CoroutineDispatcher) -> Unit) { in <lambda>()
99 val pool = Executors.newFixedThreadPool(numberOfThreads) in <lambda>()
|
| /external/tensorflow/tensorflow/lite/objc/apis/ |
| D | TFLInterpreterOptions.h | 26 @property(nonatomic) NSUInteger numberOfThreads;
|
| /external/tensorflow/tensorflow/lite/objc/sources/ |
| D | TFLInterpreter.mm | 116 if (options.numberOfThreads > 0) {
117 TfLiteInterpreterOptionsSetNumThreads(cOptions, (int32_t)options.numberOfThreads);
123 if (options.numberOfThreads > 0) {
124 xnnPackOptions.num_threads = (int32_t)options.numberOfThreads;
|
| /external/flatbuffers/tests/FlatBuffers.GRPC.Swift/Sources/server/ |
| D | main.swift | 70 let group = MultiThreadedEventLoopGroup(numberOfThreads: 1)
|
| /external/flatbuffers/tests/FlatBuffers.GRPC.Swift/Sources/client/ |
| D | main.swift | 76 let group = MultiThreadedEventLoopGroup(numberOfThreads: 1) in main()
|
| /external/tensorflow/tensorflow/lite/objc/apps/TestApp/TestApp/ |
| D | ViewController.m | 155 options.numberOfThreads = 2;
|