diff --git a/powerjob-worker-agent/pom.xml b/powerjob-worker-agent/pom.xml
index 177a00f7..a201bf70 100644
--- a/powerjob-worker-agent/pom.xml
+++ b/powerjob-worker-agent/pom.xml
@@ -10,12 +10,12 @@
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-worker-agent</artifactId>
-    <version>3.4.0</version>
+    <version>3.4.0-bugfix</version>
     <packaging>jar</packaging>
 
 
     <properties>
-        <powerjob.worker.version>3.4.0</powerjob.worker.version>
+        <powerjob.worker.version>3.4.0-bugfix</powerjob.worker.version>
         <logback.version>1.2.3</logback.version>
         <picocli.version>4.3.2</picocli.version>
 
diff --git a/powerjob-worker-samples/pom.xml b/powerjob-worker-samples/pom.xml
index 44815bba..0334a92f 100644
--- a/powerjob-worker-samples/pom.xml
+++ b/powerjob-worker-samples/pom.xml
@@ -14,7 +14,7 @@
 
     <properties>
         <springboot.version>2.2.6.RELEASE</springboot.version>
-        <powerjob.worker.starter.version>3.4.0</powerjob.worker.starter.version>
+        <powerjob.worker.starter.version>3.4.0-bugfix</powerjob.worker.starter.version>
         <fastjson.version>1.2.68</fastjson.version>
 
         <!-- 部署时跳过该module -->
diff --git a/powerjob-worker-spring-boot-starter/pom.xml b/powerjob-worker-spring-boot-starter/pom.xml
index 45191759..9865d9d2 100644
--- a/powerjob-worker-spring-boot-starter/pom.xml
+++ b/powerjob-worker-spring-boot-starter/pom.xml
@@ -10,11 +10,11 @@
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-worker-spring-boot-starter</artifactId>
-    <version>3.4.0</version>
+    <version>3.4.0-bugfix</version>
     <packaging>jar</packaging>
 
     <properties>
-        <powerjob.worker.version>3.4.0</powerjob.worker.version>
+        <powerjob.worker.version>3.4.0-bugfix</powerjob.worker.version>
         <springboot.version>2.2.6.RELEASE</springboot.version>
     </properties>
 
diff --git a/powerjob-worker/pom.xml b/powerjob-worker/pom.xml
index b320e73a..aee5b742 100644
--- a/powerjob-worker/pom.xml
+++ b/powerjob-worker/pom.xml
@@ -10,7 +10,7 @@
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-worker</artifactId>
-    <version>3.4.0</version>
+    <version>3.4.0-bugfix</version>
     <packaging>jar</packaging>
 
     <properties>
diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTrackerPool.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTrackerPool.java
index e6ffe539..474d2232 100644
--- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTrackerPool.java
+++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTrackerPool.java
@@ -25,22 +25,17 @@ public class ProcessorTrackerPool {
     /**
      * 获取 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);
         if (processorTracker == null) {
-            synchronized (ProcessorTrackerPool.class) {
-                processorTracker = processorTrackerPool.getOrDefault(instanceId, Collections.emptyMap()).get(address);
-                if (processorTracker == null) {
-                    processorTracker = creator.get();
-                    processorTrackerPool.computeIfAbsent(instanceId, ignore -> Maps.newHashMap()).put(address, processorTracker);
-                }
-            }
+            processorTracker = creator.get();
+            processorTrackerPool.computeIfAbsent(instanceId, ignore -> Maps.newHashMap()).put(address, processorTracker);
         }
         return processorTracker;
     }
 
-    public static List<ProcessorTracker> removeProcessorTracker(Long instanceId) {
+    public static synchronized List<ProcessorTracker> removeProcessorTracker(Long instanceId) {
 
         List<ProcessorTracker> res = Lists.newLinkedList();
         Map<String, ProcessorTracker> ttAddress2Pt = processorTrackerPool.remove(instanceId);