Lines Matching defs:gate

76     static void toTheStartingGate(Phaser gate) {
78 gate.arriveAndAwaitAdvance();
108 static Reader reader(final StampedLock sl, final Phaser gate) {
110 if (gate != null ) toTheStartingGate(gate);
119 static Reader readerView(final StampedLock sl, final Phaser gate) {
121 if (gate != null ) toTheStartingGate(gate);
131 static Reader reader(StampedLock sl, Phaser gate, boolean view) {
132 return view ? readerView(sl, gate) : reader(sl, gate);
138 final Phaser gate) {
140 if (gate != null ) toTheStartingGate(gate);
156 final Phaser gate) {
158 if (gate != null ) toTheStartingGate(gate);
176 final Phaser gate,
178 return view ? interruptibleReaderView(sl, timeout, unit, gate)
179 : interruptibleReader(sl, timeout, unit, gate);
187 static Writer writer(final StampedLock sl, final Phaser gate) {
189 if (gate != null ) toTheStartingGate(gate);
198 static Writer writerView(final StampedLock sl, final Phaser gate) {
200 if (gate != null ) toTheStartingGate(gate);
210 static Writer writer(StampedLock sl, Phaser gate, boolean view) {
211 return view ? writerView(sl, gate) : writer(sl, gate);
217 final Phaser gate) {
219 if (gate != null ) toTheStartingGate(gate);
235 final Phaser gate) {
237 if (gate != null ) toTheStartingGate(gate);
254 final Phaser gate,
256 return view ? interruptibleWriterView(sl, timeout, unit, gate)
257 : interruptibleWriter(sl, timeout, unit, gate);
262 final Phaser gate) {
270 return reader(sl, gate, view ^= true);
272 return interruptibleReader(sl, -1, SECONDS, gate, view ^= true);
274 return interruptibleReader(sl, LONG_DELAY_MS, MILLISECONDS, gate, view ^= true); }}
280 final Phaser gate) {
288 return writer(sl, gate, view ^= true);
290 return interruptibleWriter(sl, -1, SECONDS, gate, view ^= true);
292 return interruptibleWriter(sl, LONG_DELAY_MS, MILLISECONDS, gate, view ^= true); }}
395 Phaser gate = new Phaser(nThreads + 2);
396 Iterator<Writer> writers = writerIterator(sl, gate);
397 Iterator<Reader> readers = readerIterator(sl, gate);
410 toTheStartingGate(gate);
427 Phaser gate = new Phaser(nThreads + 2);
428 Iterator<Writer> writers = writerIterator(sl, gate);
429 Iterator<Reader> readers = readerIterator(sl, gate);
442 toTheStartingGate(gate);