|
|
|
@ -206,7 +206,7 @@ final class SubscriberInputStream<T> extends InputStream implements Flow.Subscri |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private void resume() { |
|
|
|
private void resume() { |
|
|
|
if (this.parkedThread != READY) { |
|
|
|
if (this.parkedThread.get() != READY) { |
|
|
|
Object old = this.parkedThread.getAndSet(READY); |
|
|
|
Object old = this.parkedThread.getAndSet(READY); |
|
|
|
if (old != READY) { |
|
|
|
if (old != READY) { |
|
|
|
LockSupport.unpark((Thread) old); |
|
|
|
LockSupport.unpark((Thread) old); |
|
|
|
|