Lines Matching refs:phaser
80 Phaser phaser = new Phaser(nthreads + 1);
83 pool.execute(new CasTask(a, phaser, incs));
84 report(nthreads, incs, timeTasks(phaser), a.get());
89 Phaser phaser = new Phaser(nthreads + 1);
92 pool.execute(new AdderTask(a, phaser, incs));
93 report(nthreads, incs, timeTasks(phaser), a.sum());
106 static long timeTasks(Phaser phaser) {
107 phaser.arriveAndAwaitAdvance();
109 phaser.arriveAndAwaitAdvance();
110 phaser.arriveAndAwaitAdvance();
116 final Phaser phaser;
119 AdderTask(LongAdder adder, Phaser phaser, int incs) {
121 this.phaser = phaser;
126 phaser.arriveAndAwaitAdvance();
127 phaser.arriveAndAwaitAdvance();
132 phaser.arrive();
138 final Phaser phaser;
141 CasTask(AtomicLong adder, Phaser phaser, int incs) {
143 this.phaser = phaser;
148 phaser.arriveAndAwaitAdvance();
149 phaser.arriveAndAwaitAdvance();
154 phaser.arrive();