Searched refs:barrier (Results 1 - 25 of 63) sorted by relevance

123

/openjdk10/jdk/test/java/io/Serializable/concurrentClassDescLookup/
H A DConcurrentClassDescLookup.java52 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 DBasic.java47 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 DMemoryConflictProvoker.java41 private final CyclicBarrier barrier; field in class:MemoryConflictProvoker
54 barrier = new CyclicBarrier(2);
57 barrier.await();
84 barrier.await();
H A DBusyLock.java36 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 DThreadCounts.java48 // 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 DResetPeakThreadCount.java61 // 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 DCyclicBarrierTest.java59 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 DDoubleAdderTest.java163 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 DLongAdderTest.java186 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 DMapLoops.java109 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 DThreadPriorities.java51 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 DExchangeLoops.java84 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 DLoggingDeadlock4.java40 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 DSiblingIOEHandle.java90 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 DCancelledLockLoops.java67 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 DLockOncePerThreadLoops.java83 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 DTimeoutLockLoops.java78 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 DSimpleReentrantLockLoops.java82 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 DSingleProducerMultipleConsumerLoops.java94 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 DMultipleProducersSingleConsumerLoops.java96 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 DProducerConsumerLoops.java96 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 DTimeOutShrink.java52 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 DMapLoops.java165 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 DUnbounded.java67 // 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 Dbug6190373.java50 private static final CyclicBarrier barrier = new CyclicBarrier(2); field in class:bug6190373
74 barrier.await();
76 barrier.await();

Completed in 152 milliseconds

123