From fe1b1908933d90af753049dcbc4012e5aa9d9e5e Mon Sep 17 00:00:00 2001 From: zhaohongxu <3035843598@qq.com> Date: Sun, 18 Sep 2022 00:09:48 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8Dstop=E5=B1=9E=E6=80=A7?= =?UTF-8?q?=E5=8F=AF=E8=83=BD=E4=BC=9A=E5=87=BA=E7=8E=B0=E7=9A=84=E4=B8=8D?= =?UTF-8?q?=E5=8F=AF=E8=A7=81=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/java3y/austin/support/pending/AbstractLazyPending.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/austin-support/src/main/java/com/java3y/austin/support/pending/AbstractLazyPending.java b/austin-support/src/main/java/com/java3y/austin/support/pending/AbstractLazyPending.java index 6e5f313..e3d6075 100644 --- a/austin-support/src/main/java/com/java3y/austin/support/pending/AbstractLazyPending.java +++ b/austin-support/src/main/java/com/java3y/austin/support/pending/AbstractLazyPending.java @@ -40,7 +40,7 @@ public abstract class AbstractLazyPending { /** * 是否终止线程 */ - private Boolean stop = false; + private volatile Boolean stop = false; /** * 单线程消费 阻塞队列的数据