/openjdk10/jdk/test/java/io/Serializable/concurrentClassDescLookup/ |
H A D | ConcurrentClassDescLookup.java | 52 Object barrier; field in class:SuccessfulLookup 55 SuccessfulLookup(Class cl, long suid, Object barrier) { argument 58 this.barrier = barrier; 62 synchronized (barrier) { 63 try { barrier.wait(); } catch (InterruptedException ex) {} 76 Object barrier; field in class:FailingLookup 79 FailingLookup(Class cl, Object barrier) { argument 81 this.barrier = barrier; [all...] |
/openjdk10/jdk/test/java/util/concurrent/CyclicBarrier/ |
H A D | Basic.java | 47 private static void checkBroken(final CyclicBarrier barrier) { argument 48 check(barrier.isBroken()); 49 equal(barrier.getNumberWaiting(), 0); 52 () -> barrier.await(), 53 () -> barrier.await(100, MILLISECONDS)); 56 private static void reset(CyclicBarrier barrier) { argument 57 barrier.reset(); 58 check(! barrier.isBroken()); 59 equal(barrier.getNumberWaiting(), 0); 106 private static Awaiter awaiter(final CyclicBarrier barrier) { argument 114 awaiter(final CyclicBarrier barrier, final long millis) argument 124 awaiterIterator(final CyclicBarrier barrier) argument [all...] |
/openjdk10/hotspot/test/compiler/testlibrary/rtm/ |
H A D | MemoryConflictProvoker.java | 41 private final CyclicBarrier barrier; field in class:MemoryConflictProvoker 54 barrier = new CyclicBarrier(2); 57 barrier.await(); 84 barrier.await();
|
H A D | BusyLock.java | 36 private final CyclicBarrier barrier; field in class:BusyLock 51 this.barrier = new CyclicBarrier(2); 58 barrier.await(); 69 barrier.await();
|
/openjdk10/jdk/test/java/lang/management/ThreadMXBean/ |
H A D | ThreadCounts.java | 48 // barrier for threads communication 49 private static Barrier barrier = new Barrier(DAEMON_THREADS); field in class:ThreadCounts 56 barrier.set(DAEMON_THREADS); 64 barrier.await(); 78 barrier.set(USER_THREADS_1); 86 barrier.await(); 99 barrier.set(DAEMON_THREADS); 104 barrier.await(); 116 barrier.set(USER_THREADS_2); 124 barrier [all...] |
H A D | ResetPeakThreadCount.java | 61 // barrier for threads communication 62 private static final Barrier barrier = new Barrier(DAEMON_THREADS_1); field in class:ResetPeakThreadCount 138 barrier.set(count); 148 barrier.await(); 176 barrier.set(count); 184 barrier.await(); 255 barrier.signal(); 268 barrier.signal();
|
/openjdk10/jdk/test/java/util/concurrent/tck/ |
H A D | CyclicBarrierTest.java | 59 void awaitNumberWaiting(CyclicBarrier barrier, int numberOfWaiters) { argument 61 while (barrier.getNumberWaiting() != numberOfWaiters) { 99 * A 1-party barrier triggers after single await 111 * The supplied barrier action is run at barrier 127 * A 2-party/thread barrier triggers after both threads invoke await 273 * A reset of an active barrier causes waiting threads to throw 301 * A reset before threads enter barrier does not throw 323 * All threads block while a barrier is broken. 352 * Reset of a non-broken barrier doe [all...] |
H A D | DoubleAdderTest.java | 163 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); 165 pool.execute(new AdderTask(a, barrier, incs)); 166 barrier.await(); 167 barrier.await(); 176 final CyclicBarrier barrier; field in class:DoubleAdderTest.AdderTask 179 AdderTask(DoubleAdder adder, CyclicBarrier barrier, int incs) { argument 181 this.barrier = barrier; 187 barrier.await(); 192 barrier [all...] |
H A D | LongAdderTest.java | 186 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); 188 pool.execute(new AdderTask(a, barrier, incs)); 189 barrier.await(); 190 barrier.await(); 199 final CyclicBarrier barrier; field in class:LongAdderTest.AdderTask 202 AdderTask(LongAdder adder, CyclicBarrier barrier, int incs) { argument 204 this.barrier = barrier; 210 barrier.await(); 215 barrier [all...] |
/openjdk10/jdk/test/java/util/concurrent/locks/ReentrantReadWriteLock/ |
H A D | MapLoops.java | 109 CyclicBarrier barrier = new CyclicBarrier(1, timer); 110 new Runner(map, key, barrier, rnd.split()).run(); 118 CyclicBarrier barrier = new CyclicBarrier(i+1, timer); 120 pool.execute(new Runner(map, key, barrier, rnd.split())); 121 barrier.await(); 122 barrier.await(); 138 final CyclicBarrier barrier; field in class:MapLoops.Runner 145 CyclicBarrier barrier, 149 this.barrier = barrier; 143 Runner(Map<Integer,Integer> map, Integer[] key, CyclicBarrier barrier, SplittableRandom rnd) argument [all...] |
/openjdk10/hotspot/test/runtime/Thread/ |
H A D | ThreadPriorities.java | 51 final CyclicBarrier barrier = 62 barrier.await(); // 1st 63 barrier.await(); // 2nd 70 barrier.await(); // 1st 93 barrier.await(); // 2nd 94 barrier.reset();
|
/openjdk10/jdk/test/java/util/concurrent/Exchanger/ |
H A D | ExchangeLoops.java | 84 final CyclicBarrier barrier; field in class:ExchangeLoops.Stage 91 barrier = b; 97 barrier.await(); 116 barrier.await(); 128 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1, timer); 132 pool.execute(new Stage(l, r, barrier, iters)); 136 barrier.await(); 137 barrier.await();
|
/openjdk10/jdk/test/java/util/logging/ |
H A D | LoggingDeadlock4.java | 40 private static CountDownLatch barrier = new CountDownLatch(1); field in class:LoggingDeadlock4 63 barrier.await(); // wait for race to start 81 barrier.await(); // wait for race to start 97 barrier.countDown(); // start the race
|
/openjdk10/jdk/test/java/lang/ProcessBuilder/ |
H A D | SiblingIOEHandle.java | 90 private static boolean waitBarrier(CyclicBarrier barrier) { argument 92 barrier.await(); 103 private CyclicBarrier barrier; field in class:SiblingIOEHandle.ProcessC 106 public ProcessC(CyclicBarrier barrier) { argument 107 this.barrier = barrier; 113 if (waitBarrier(barrier)) { 145 final CyclicBarrier barrier = new CyclicBarrier(2); 147 ProcessC processC = new ProcessC(barrier); 151 if (!waitBarrier(barrier)) { [all...] |
/openjdk10/jdk/test/java/util/concurrent/locks/ReentrantLock/ |
H A D | CancelledLockLoops.java | 67 private final CyclicBarrier barrier; field in class:CancelledLockLoops.Loops 73 barrier = new CyclicBarrier(nthreads+1, timer); 84 barrier.await(); 93 barrier.await(); 118 barrier.await(); 154 barrier.await();
|
H A D | LockOncePerThreadLoops.java | 83 private final CyclicBarrier barrier; field in class:LockOncePerThreadLoops.ReentrantLockLoop 85 barrier = new CyclicBarrier(nthreads+1, timer); 93 barrier.await(); 94 barrier.await(); 108 barrier.await(); 126 barrier.await();
|
H A D | TimeoutLockLoops.java | 78 private final CyclicBarrier barrier; field in class:TimeoutLockLoops.ReentrantLockLoop 83 barrier = new CyclicBarrier(nthreads+1, timer); 92 barrier.await(); 96 barrier.await(); 111 barrier.await(); 124 barrier.await();
|
H A D | SimpleReentrantLockLoops.java | 82 private final CyclicBarrier barrier; field in class:SimpleReentrantLockLoops.ReentrantLockLoop 86 barrier = new CyclicBarrier(nthreads+1, timer); 92 barrier.await(); 93 barrier.await(); 109 barrier.await(); 131 barrier.await();
|
/openjdk10/jdk/test/java/util/concurrent/BlockingQueue/ |
H A D | SingleProducerMultipleConsumerLoops.java | 94 final CyclicBarrier barrier; field in class:SingleProducerMultipleConsumerLoops 101 this.barrier = new CyclicBarrier(consumers + 2, timer); 109 barrier.await(); 110 barrier.await(); 133 barrier.await(); 137 barrier.await(); 145 barrier.await(); 158 barrier.await();
|
H A D | MultipleProducersSingleConsumerLoops.java | 96 final CyclicBarrier barrier; field in class:MultipleProducersSingleConsumerLoops 104 this.barrier = new CyclicBarrier(nproducers + 2, timer); 111 barrier.await(); 112 barrier.await(); 135 barrier.await(); 145 barrier.await(); 151 barrier.await(); 157 barrier.await();
|
H A D | ProducerConsumerLoops.java | 96 final CyclicBarrier barrier; field in class:ProducerConsumerLoops 104 this.barrier = new CyclicBarrier(2 * pairs + 1, timer); 112 barrier.await(); 113 barrier.await(); 136 barrier.await(); 145 barrier.await(); 151 barrier.await(); 159 barrier.await();
|
/openjdk10/jdk/test/java/util/concurrent/ThreadPoolExecutor/ |
H A D | TimeOutShrink.java | 52 final CyclicBarrier barrier = new CyclicBarrier(2*n+1); 59 barrier.await(); 60 barrier.await(); 65 barrier.await(); 67 barrier.await();
|
/openjdk10/jdk/test/java/util/concurrent/ConcurrentHashMap/ |
H A D | MapLoops.java | 165 CyclicBarrier barrier = new CyclicBarrier(i+1, timer); 168 pool.execute(new Runner(map, key, barrier, rnd.split())); 169 barrier.await(); 170 barrier.await(); 182 final CyclicBarrier barrier; field in class:MapLoops.Runner 189 CyclicBarrier barrier, 193 this.barrier = barrier; 233 barrier.await(); 237 barrier 187 Runner(Map<Integer,Integer> map, Integer[] key, CyclicBarrier barrier, SplittableRandom rnd) argument [all...] |
/openjdk10/jdk/test/java/nio/channels/AsynchronousChannelGroup/ |
H A D | Unbounded.java | 67 // the barrier where all threads (plus the main thread) wait 68 final CyclicBarrier barrier = new CyclicBarrier(CONCURRENCY_COUNT+1); 78 barrier.await(); 99 // wait for all threads to reach the barrier 100 System.out.println("Waiting for all threads to reach barrier"); 101 barrier.await();
|
/openjdk10/jdk/test/javax/swing/plaf/metal/MetalUtils/ |
H A D | bug6190373.java | 50 private static final CyclicBarrier barrier = new CyclicBarrier(2); field in class:bug6190373 74 barrier.await(); 76 barrier.await();
|