Searched refs:leader (Results 1 – 3 of 3) sorted by relevance
99 private Thread leader; field in DelayQueue149 leader = null; in offer()223 if (leader != null) in take()227 leader = thisThread; in take()231 if (leader == thisThread) in take()232 leader = null; in take()238 if (leader == null && q.peek() != null) in take()273 if (nanos < delay || leader != null) in poll()277 leader = thisThread; in poll()282 if (leader == thisThread) in poll()[all …]
953 private Thread leader; field in ScheduledThreadPoolExecutor.DelayedWorkQueue1119 leader = null; in offer()1182 if (leader != null) in take()1186 leader = thisThread; in take()1190 if (leader == thisThread) in take()1191 leader = null; in take()1197 if (leader == null && queue[0] != null) in take()1223 if (nanos < delay || leader != null) in poll()1227 leader = thisThread; in poll()1232 if (leader == thisThread) in poll()[all …]
1283 ReaderNode leader; long nextState; in acquireRead() local1301 } else if ((leader = (ReaderNode)t) == tail) { // try to cowait in acquireRead()1303 if (leader.status < 0 || leader.prev == null) in acquireRead()1310 ReaderNode c = leader.cowaiters; in acquireRead()1312 attached = leader.casCowaiters(c, node); in acquireRead()1324 return cancelCowaiter(node, leader, interrupted); in acquireRead()1330 signalCowaiters(leader); in acquireRead()1432 private void unlinkCowaiter(ReaderNode node, ReaderNode leader) { in unlinkCowaiter() argument1433 if (leader != null) { in unlinkCowaiter()1434 while (leader.prev != null && leader.status >= 0) { in unlinkCowaiter()[all …]