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: concurrency safety in ProcessotTrackerPool

Browse Source
This commit is contained in:
tjq 2020-12-05 10:36:33 +08:00
parent b4f92bbc25
commit 9db9d0d01f
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTrackerPool.java
View File

@ -25,17 +25,12 @@ public class ProcessorTrackerPool {
/** /**
* 获取 ProcessorTracker，如果不存在则创建 * 获取 ProcessorTracker，如果不存在则创建
*/ */
public static ProcessorTracker getProcessorTracker(Long instanceId, String address, Supplier<ProcessorTracker> creator) { public static synchronized ProcessorTracker getProcessorTracker(Long instanceId, String address, Supplier<ProcessorTracker> creator) {
ProcessorTracker processorTracker = processorTrackerPool.getOrDefault(instanceId, Collections.emptyMap()).get(address); ProcessorTracker processorTracker = processorTrackerPool.getOrDefault(instanceId, Collections.emptyMap()).get(address);
if (processorTracker == null) { if (processorTracker == null) {
synchronized (ProcessorTrackerPool.class) { processorTracker = creator.get();
processorTracker = processorTrackerPool.getOrDefault(instanceId, Collections.emptyMap()).get(address); processorTrackerPool.computeIfAbsent(instanceId, ignore -> Maps.newHashMap()).put(address, processorTracker);
if (processorTracker == null) {
processorTracker = creator.get();
processorTrackerPool.computeIfAbsent(instanceId, ignore -> Maps.newHashMap()).put(address, processorTracker);
}
}
} }
return processorTracker; return processorTracker;
} }