Searched refs:barrier (Results 26 - 50 of 63) sorted by relevance

123

/openjdk10/jdk/test/java/util/concurrent/FutureTask/
H A DCancelledFutureLoops.java95 private final CyclicBarrier barrier; field in class:CancelledFutureLoops.FutureLoop
100 barrier = new CyclicBarrier(nthreads+1, timer);
109 barrier.await();
140 barrier.await();
/openjdk10/jdk/test/javax/swing/undo/UndoManager/
H A DAbstractDocumentUndoConcurrentTest.java38 static CyclicBarrier barrier = new CyclicBarrier(3); field in class:AbstractDocumentUndoConcurrentTest
68 barrier.await();
85 barrier.await();
102 barrier.await();
/openjdk10/jdk/test/java/util/concurrent/BlockingQueue/
H A DCancelledProducerConsumerLoops.java91 final CyclicBarrier barrier; field in class:CancelledProducerConsumerLoops
99 this.barrier = new CyclicBarrier(npairs * 2 + 1, timer);
110 barrier.await();
152 barrier.await();
171 barrier.await();
/openjdk10/hotspot/test/compiler/testlibrary/rtm/
H A DAbortProvoker.java52 CyclicBarrier barrier = new CyclicBarrier(2);
57 barrier.await();
76 barrier.await();
/openjdk10/jdk/test/java/util/concurrent/ConcurrentQueues/
H A DConcurrentQueueLoops.java124 final CyclicBarrier barrier; field in class:ConcurrentQueueLoops.Stage
128 barrier = b;
136 barrier.await();
167 CyclicBarrier barrier = new CyclicBarrier(n + 1, timer);
171 results.add(pool.submit(new Stage(q, barrier, items)));
175 barrier.await();
/openjdk10/hotspot/src/jdk.internal.vm.compiler/share/classes/org.graalvm.compiler.hotspot/src/org/graalvm/compiler/hotspot/phases/
H A DWriteBarrierVerificationPhase.java56 * Verification phase that checks if, for every write, at least one write barrier is present at all
57 * paths leading to the previous safepoint. For every write, necessitating a write barrier, a
59 * paths. If, for a certain path, no write barrier satisfying the processed write is found, an
92 * attached write barrier.
103 throw new AssertionError("Write barrier must be present " + write.toString(Verbosity.All) + " / " + write.inputs());
150 // Read nodes with barrier attached (G1 Ref field) are not validated yet.
191 private static boolean validateBarrier(FixedAccessNode write, ObjectWriteBarrier barrier) { argument
192 assert write instanceof WriteNode || write instanceof LogicCompareAndSwapNode || write instanceof LoweredAtomicReadAndWriteNode : "Node must be of type requiring a write barrier " + write;
193 if (!barrier.usePrecise()) {
194 if (barrier
[all...]
H A DWriteBarrierAdditionPhase.java80 G1ReferentFieldReadBarrier barrier = graph.add(new G1ReferentFieldReadBarrier(node.getAddress(), node, false));
81 graph.addAfterFixed(node, barrier);
83 assert node.getBarrierType() == BarrierType.NONE : "Non precise read barrier has been attached to read node.";
103 // Serial barrier isn't needed for null value
128 throw new GraalError("unexpected barrier type: " + barrierType);
149 throw new GraalError("unexpected barrier type: " + barrierType);
170 throw new GraalError("unexpected barrier type: " + barrierType);
/openjdk10/jdk/test/java/nio/channels/Selector/
H A DWakeup.java49 // barrier is used to synchronize sleeper thread and checking
52 private static CyclicBarrier barrier = new CyclicBarrier(2); field in class:Wakeup.Sleeper
94 barrier.await();
102 barrier.await();
103 System.err.println("wait barrier successfully, " + waits);
/openjdk10/jdk/test/java/util/concurrent/locks/Lock/
H A DCheckedLockLoops.java113 CyclicBarrier barrier; field in class:CheckedLockLoops.LockLoop
131 barrier = new CyclicBarrier(nthreads+1, timer);
134 barrier.await();
135 barrier.await();
149 barrier.await();
151 barrier.await();
/openjdk10/jdk/test/java/util/concurrent/locks/ReentrantReadWriteLock/
H A DCount.java77 final CyclicBarrier barrier = new CyclicBarrier(nThreads);
87 barrier.await();
92 barrier.await();
97 barrier.await();
102 barrier.await();
107 barrier.await();
/openjdk10/jdk/test/java/lang/management/MemoryMXBean/
H A DCollectionUsageThreshold.java60 // barrier for the main thread to wait until the checker thread
62 private static final CyclicBarrier barrier = new CyclicBarrier(2); field in class:CollectionUsageThreshold
186 // barrier.await() to signal the main thread to resume its work.
189 barrier.await();
254 barrier.await();
259 // reset the barrier to cause BrokenBarrierException to avoid hanging
260 barrier.reset();
/openjdk10/hotspot/test/runtime/Thread/
H A DTestThreadDumpMonitorContention.java91 final static Object barrier = new Object(); field in class:TestThreadDumpMonitorContention
138 synchronized (barrier) {
141 barrier.notify();
151 synchronized (barrier) {
158 barrier.wait();
/openjdk10/jdk/test/java/util/concurrent/tck/
H A DBlockingQueueTest.java240 final CheckedBarrier barrier = new CheckedBarrier(2);
248 barrier.await();
259 barrier.await();
269 barrier.await();
274 barrier.await();
H A DLinkedBlockingDequeTest.java1154 final CheckedBarrier barrier = new CheckedBarrier(2);
1161 barrier.await();
1171 barrier.await();
1180 barrier.await();
1184 barrier.await();
1437 final CheckedBarrier barrier = new CheckedBarrier(2);
1444 barrier.await();
1455 barrier.await();
1465 barrier.await();
1470 barrier
[all...]
H A DReentrantLockTest.java477 final CyclicBarrier barrier = new CyclicBarrier(2);
482 barrier.await();
483 barrier.await();
487 barrier.await();
489 barrier.await();
/openjdk10/hotspot/src/share/vm/gc/shared/
H A DcardTableModRefBS.cpp120 log_trace(gc, barrier)("CardTableModRefBS::CardTableModRefBS: ");
121 log_trace(gc, barrier)(" &_byte_map[0]: " INTPTR_FORMAT " &_byte_map[_last_valid_index]: " INTPTR_FORMAT,
123 log_trace(gc, barrier)(" byte_map_base: " INTPTR_FORMAT, p2i(byte_map_base));
347 log_trace(gc, barrier)("CardTableModRefBS::resize_covered_region: ");
348 log_trace(gc, barrier)(" _covered[%d].start(): " INTPTR_FORMAT " _covered[%d].last(): " INTPTR_FORMAT,
350 log_trace(gc, barrier)(" _committed[%d].start(): " INTPTR_FORMAT " _committed[%d].last(): " INTPTR_FORMAT,
352 log_trace(gc, barrier)(" byte_for(start): " INTPTR_FORMAT " byte_for(last): " INTPTR_FORMAT,
354 log_trace(gc, barrier)(" addr_for(start): " INTPTR_FORMAT " addr_for(last): " INTPTR_FORMAT,
364 // fact that the write barrier may be either precise or imprecise.
/openjdk10/hotspot/src/share/vm/runtime/
H A Dmutex.hpp118 barrier = safepoint + 1, enumerator in enum:Monitor::lock_types
119 nonleaf = barrier + 1,
/openjdk10/hotspot/src/share/vm/gc/g1/
H A Dg1OopClosures.inline.hpp222 template <G1Barrier barrier, G1Mark do_mark_object, bool use_ext>
224 void G1ParCopyClosure<barrier, do_mark_object, use_ext>::do_oop_work(T* p) {
252 if (barrier == G1BarrierKlass) {
H A Dg1SATBCardTableModRefBS.cpp151 log_trace(gc, barrier)("G1SATBCardTableModRefBS::G1SATBCardTableModRefBS: ");
152 log_trace(gc, barrier)(" &_byte_map[0]: " INTPTR_FORMAT " &_byte_map[_last_valid_index]: " INTPTR_FORMAT,
154 log_trace(gc, barrier)(" byte_map_base: " INTPTR_FORMAT, p2i(byte_map_base));
H A Dg1OopClosures.hpp142 template <G1Barrier barrier, G1Mark do_mark_object, bool use_ext>
/openjdk10/jdk/test/java/util/concurrent/ThreadPoolExecutor/
H A DConfigChanges.java105 static Runnable waiter(final CyclicBarrier barrier) { argument
107 try { barrier.await(); barrier.await(); }
/openjdk10/hotspot/src/share/vm/gc/parallel/
H A DcardTableExtension.cpp82 // No point in asserting barrier set type here. Need to make CardTableExtension
83 // a unique barrier set type.
474 log_trace(gc, barrier)("CardTableModRefBS::resize_covered_region: ");
475 log_trace(gc, barrier)(" _covered[%d].start(): " INTPTR_FORMAT " _covered[%d].last(): " INTPTR_FORMAT,
477 log_trace(gc, barrier)(" _committed[%d].start(): " INTPTR_FORMAT " _committed[%d].last(): " INTPTR_FORMAT,
479 log_trace(gc, barrier)(" byte_for(start): " INTPTR_FORMAT " byte_for(last): " INTPTR_FORMAT,
481 log_trace(gc, barrier)(" addr_for(start): " INTPTR_FORMAT " addr_for(last): " INTPTR_FORMAT,
/openjdk10/hotspot/src/share/vm/logging/
H A DlogTag.hpp42 LOG_TAG(barrier) \
H A DlogPrefix.hpp50 LOG_PREFIX(GCId::print_prefix, LOG_TAGS(gc, barrier)) \
/openjdk10/hotspot/src/jdk.internal.vm.compiler/share/classes/org.graalvm.compiler.word/src/org/graalvm/compiler/word/
H A DWordOperationPlugin.java438 final BarrierType barrier = (op == Opcode.READ_BARRIERED ? BarrierType.PRECISE : BarrierType.NONE);
441 return readOp(b, readKind, address, location, barrier, compressible);
456 final BarrierType barrier = (op == Opcode.WRITE_BARRIERED ? BarrierType.PRECISE : BarrierType.NONE);
459 b.add(new JavaWriteNode(writeKind, address, location, value, barrier, compressible));

Completed in 122 milliseconds

123