Home
last modified time | relevance | path

Searched defs:startBarrier (Results 1 – 4 of 4) sorted by relevance

/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DConcurrencyTest.java104 public ClientWorker(CyclicBarrier startBarrier, CountDownLatch responsesDoneSignal) { in ClientWorker()
131 private final CyclicBarrier startBarrier; field in ConcurrencyTest.ClientWorker
175 CyclicBarrier startBarrier = new CyclicBarrier(NUM_CONCURRENT_REQUESTS); in serverStreamingTest() local
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DUnconfinedConcurrentStressTest.kt25 val startBarrier = CyclicBarrier(threads + 1) in <lambda>() constant
DCancellableContinuationResumeCloseStressTest.kt17 private val startBarrier = CyclicBarrier(3) in <lambda>() constant
/external/icu/android_icu4j/testing/src/com/android/i18n/test/timezone/
DTimeZoneIntegrationTest.java93 CyclicBarrier startBarrier = new CyclicBarrier(2); in testSetDefaultDeadlock() local
140 CyclicBarrier startBarrier = new CyclicBarrier(2); in testSetDefaultRace() local