261 |
|
int s; |
262 |
|
while ((s = status) >= 0) { |
263 |
|
synchronized (this) { |
264 |
< |
if (UNSAFE.compareAndSwapInt(this, statusOffset, s, SIGNAL)){ |
264 |
> |
if (UNSAFE.compareAndSwapInt(this, statusOffset, s, SIGNAL)) { |
265 |
|
boolean interrupted = false; |
266 |
|
while (status >= 0) { |
267 |
|
try { |
661 |
|
else { |
662 |
|
while ((s = status) >= 0) { |
663 |
|
synchronized (this) { // interruptible form of awaitDone |
664 |
< |
if (UNSAFE.compareAndSwapInt(this, statusOffset, |
664 |
> |
if (UNSAFE.compareAndSwapInt(this, statusOffset, |
665 |
|
s, SIGNAL)) { |
666 |
|
while (status >= 0) |
667 |
|
wait(); |