third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: bug of deadlock

Browse Source
This commit is contained in:
tjq 2023-01-28 10:13:28 +08:00
parent ccbe11ed0e
commit 5d9ce2daf0
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/manager/LightTaskTrackerManager.java
View File

@ -21,8 +21,11 @@ public class LightTaskTrackerManager {
return INSTANCE_ID_2_TASK_TRACKER.get(instanceId); return INSTANCE_ID_2_TASK_TRACKER.get(instanceId);
} }
public static LightTaskTracker removeTaskTracker(Long instanceId) { public static void removeTaskTracker(Long instanceId) {
return INSTANCE_ID_2_TASK_TRACKER.remove(instanceId); // 忽略印度的 IDE 警告，这个判断非常有用！！！不加这个判断会导致：如果创建 TT（先执行 computeIfAbsent 正在将TT添加到 HashMap） 时报错，TT 主动调用 destroy 销毁（从 HashMap移除该 TT）时死锁
if (INSTANCE_ID_2_TASK_TRACKER.containsKey(instanceId)) {
INSTANCE_ID_2_TASK_TRACKER.remove(instanceId);
}
} }
public static void atomicCreateTaskTracker(Long instanceId, Function<Long, LightTaskTracker> creator) { public static void atomicCreateTaskTracker(Long instanceId, Function<Long, LightTaskTracker> creator) {