diff --git a/renren-admin/src/main/java/io/renren/common/aspect/ActivitiNoticeAspect.java b/renren-admin/src/main/java/io/renren/common/aspect/ActivitiNoticeAspect.java index 0d3519fd..9fc31c54 100644 --- a/renren-admin/src/main/java/io/renren/common/aspect/ActivitiNoticeAspect.java +++ b/renren-admin/src/main/java/io/renren/common/aspect/ActivitiNoticeAspect.java @@ -178,9 +178,10 @@ public class ActivitiNoticeAspect { new Thread(() -> { try { Thread.sleep(200); - work_.remove(TaskListener.EVENTNAME_COMPLETE + kv.get("id").toString()); } catch (InterruptedException e) { throw new RuntimeException(e); + } finally { + work_.remove(TaskListener.EVENTNAME_COMPLETE + kv.get("id").toString()); } }).start(); }); @@ -278,9 +279,10 @@ public class ActivitiNoticeAspect { new Thread(() -> { try { Thread.sleep(200); - work_.remove(ExecutionListener.EVENTNAME_END + kv.get("id").toString()); } catch (InterruptedException e) { throw new RuntimeException(e); + } finally { + work_.remove(ExecutionListener.EVENTNAME_END + kv.get("id").toString()); } }).start(); });