/openjdk10/jdk/test/java/util/concurrent/FutureTask/ |
H A D | CancelledFutureLoops.java | 95 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 D | AbstractDocumentUndoConcurrentTest.java | 38 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 D | CancelledProducerConsumerLoops.java | 91 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 D | AbortProvoker.java | 52 CyclicBarrier barrier = new CyclicBarrier(2); 57 barrier.await(); 76 barrier.await();
|
/openjdk10/jdk/test/java/util/concurrent/ConcurrentQueues/ |
H A D | ConcurrentQueueLoops.java | 124 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 D | WriteBarrierVerificationPhase.java | 56 * 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 D | WriteBarrierAdditionPhase.java | 80 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 D | Wakeup.java | 49 // 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 D | CheckedLockLoops.java | 113 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 D | Count.java | 77 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 D | CollectionUsageThreshold.java | 60 // 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 D | TestThreadDumpMonitorContention.java | 91 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 D | BlockingQueueTest.java | 240 final CheckedBarrier barrier = new CheckedBarrier(2); 248 barrier.await(); 259 barrier.await(); 269 barrier.await(); 274 barrier.await();
|
H A D | LinkedBlockingDequeTest.java | 1154 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 D | ReentrantLockTest.java | 477 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 D | cardTableModRefBS.cpp | 120 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 D | mutex.hpp | 118 barrier = safepoint + 1, enumerator in enum:Monitor::lock_types 119 nonleaf = barrier + 1,
|
/openjdk10/hotspot/src/share/vm/gc/g1/ |
H A D | g1OopClosures.inline.hpp | 222 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 D | g1SATBCardTableModRefBS.cpp | 151 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 D | g1OopClosures.hpp | 142 template <G1Barrier barrier, G1Mark do_mark_object, bool use_ext>
|
/openjdk10/jdk/test/java/util/concurrent/ThreadPoolExecutor/ |
H A D | ConfigChanges.java | 105 static Runnable waiter(final CyclicBarrier barrier) { argument 107 try { barrier.await(); barrier.await(); }
|
/openjdk10/hotspot/src/share/vm/gc/parallel/ |
H A D | cardTableExtension.cpp | 82 // 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 D | logTag.hpp | 42 LOG_TAG(barrier) \
|
H A D | logPrefix.hpp | 50 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 D | WordOperationPlugin.java | 438 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));
|