We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9bfa082 commit 5224e97Copy full SHA for 5224e97
src/java.base/share/classes/java/util/concurrent/SubmissionPublisher.java
@@ -1059,7 +1059,7 @@ static final class BufferedSubscription<T>
1059
final Subscriber<? super T> subscriber;
1060
final BiConsumer<? super Subscriber<? super T>, ? super Throwable> onNextHandler;
1061
Executor executor; // null on error
1062
- Thread waiter; // blocked producer thread
+ volatile Thread waiter; // blocked producer thread
1063
Throwable pendingError; // holds until onError issued
1064
BufferedSubscription<T> next; // used only by publisher
1065
BufferedSubscription<T> nextRetry; // used only by publisher
0 commit comments