Fix SubscriberInputStream.resume()

izeye · izeye · commit 19c020ef9483 · 2025-12-08T22:51:23.000+09:00
See gh-35468 Signed-off-by: Johnny Lim <izeye@naver.com>
diff --git a/spring-core/src/main/java/org/springframework/core/io/buffer/SubscriberInputStream.java b/spring-core/src/main/java/org/springframework/core/io/buffer/SubscriberInputStream.java
@@ -185,7 +185,7 @@ int addWork() {
 	}
 
 	private void resume() {
-		if (this.parkedThread != READY) {
+		if (this.parkedThread.get() != READY) {
 			Object old = this.parkedThread.getAndSet(READY);
 			if (old != READY) {
 				LockSupport.unpark((Thread)old);

Original file line number	Diff line number	Diff line change
`@@ -185,7 +185,7 @@ int addWork() {`
`185`	`185`	`}`
`186`	`186`
`187`	`187`	`private void resume() {`
`188`		`- if (this.parkedThread != READY) {`
	`188`	`+ if (this.parkedThread.get() != READY) {`
`189`	`189`	`Object old = this.parkedThread.getAndSet(READY);`
`190`	`190`	`if (old != READY) {`
`191`	`191`	`LockSupport.unpark((Thread)old);`