1052 |
|
long delay = first.getDelay(NANOSECONDS); |
1053 |
|
if (delay <= 0) |
1054 |
|
return finishPoll(first); |
1055 |
< |
else if (leader != null) |
1055 |
> |
first = null; // don't retain ref while waiting |
1056 |
> |
if (leader != null) |
1057 |
|
available.await(); |
1058 |
|
else { |
1059 |
|
Thread thisThread = Thread.currentThread(); |
1093 |
|
return finishPoll(first); |
1094 |
|
if (nanos <= 0) |
1095 |
|
return null; |
1096 |
+ |
first = null; // don't retain ref while waiting |
1097 |
|
if (nanos < delay || leader != null) |
1098 |
|
nanos = available.awaitNanos(nanos); |
1099 |
|
else { |