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 a21593cc5d6d25b7ac4deb79539d65f125c7bacd..28df9cc5c9a45de6ecd40ddcb39f67d4dfe0dff8 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秒执行一次