From 7cf6add7baeb925b48dfee761d3576c78fe1d820 Mon Sep 17 00:00:00 2001 From: yuanhuiliang715 Date: Sun, 2 Apr 2023 10:48:24 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E9=94=81=E8=B6=85=E6=97=B6?= =?UTF-8?q?=E6=97=B6=E9=97=B4(=E4=B8=BB=E7=BA=BF=E7=A8=8B=E5=AE=8C?= =?UTF-8?q?=E6=88=90=E5=90=8E=EF=BC=8C=E5=AD=90=E7=BA=BF=E7=A8=8B=E9=80=80?= =?UTF-8?q?=E5=87=BA=E7=BA=BF=E7=A8=8B=E5=BE=AA=E7=8E=AF)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../concurrent/chapter19/task/UpdateLockTimeoutTask.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/mykit-concurrent-chapter19/src/main/java/io/binghe/concurrent/chapter19/task/UpdateLockTimeoutTask.java b/mykit-concurrent-chapter19/src/main/java/io/binghe/concurrent/chapter19/task/UpdateLockTimeoutTask.java index a21593c..28df9cc 100644 --- a/mykit-concurrent-chapter19/src/main/java/io/binghe/concurrent/chapter19/task/UpdateLockTimeoutTask.java +++ b/mykit-concurrent-chapter19/src/main/java/io/binghe/concurrent/chapter19/task/UpdateLockTimeoutTask.java @@ -27,6 +27,10 @@ public class UpdateLockTimeoutTask implements Runnable{ //以传递的线程id为key，当前执行更新超时时间的线程为value，保存到redis中 stringRedisTemplate.opsForValue().set(currentThreadId, String.valueOf(Thread.currentThread().getId())); while (true){ + //线程停止 退出循环 + if(Thread.interrupted()){ + break; + } stringRedisTemplate.expire(key, 30, TimeUnit.SECONDS); try { //每个10秒执行一次 -- Gitee