@@ -50,17 +50,17 @@ public class BaseMsgThread extends Thread {
     /**
      * 当前线程成功数
      */
-    public final ThreadLocal<Integer> currentThreadSuccessCount = ThreadLocal.withInitial(() -> 0);
+    public final ThreadLocal<Integer> successCountLocal = ThreadLocal.withInitial(() -> 0);
 
     /**
      * 当前线程失败数
      */
-    public final ThreadLocal<Integer> currentThreadFailCount = ThreadLocal.withInitial(() -> 0);
+    public final ThreadLocal<Integer> failCountLocal = ThreadLocal.withInitial(() -> 0);
 
     /**
      * 线程列表table
      */
-    public JTable pushThreadTable;
+    public final ThreadLocal<JTable> pushTableLocal = new ThreadLocal<>();
 
     /**
      * 当前线程所在的线程列表行
@@ -95,13 +95,13 @@ public void initCurrentThread() {
         list = PushData.toSendList.subList(startIndex, endIndex);
 
         // 初始化线程列表行
-        pushThreadTable = PushForm.getInstance().getPushThreadTable();
-        currentThreadSuccessCount.set(0);
-        currentThreadFailCount.set(0);
-        pushThreadTable.setValueAt(currentThreadSuccessCount.get(), tableRow, 2);
-        pushThreadTable.setValueAt(currentThreadFailCount.get(), tableRow, 3);
-        pushThreadTable.setValueAt(list.size(), tableRow, 4);
-        pushThreadTable.setValueAt(0, tableRow, 5);
+        pushTableLocal.set(PushForm.getInstance().getPushThreadTable());
+        successCountLocal.set(0);
+        failCountLocal.set(0);
+        pushTableLocal.get().setValueAt(successCountLocal.get(), tableRow, 2);
+        pushTableLocal.get().setValueAt(failCountLocal.get(), tableRow, 3);
+        pushTableLocal.get().setValueAt(list.size(), tableRow, 4);
+        pushTableLocal.get().setValueAt(0, tableRow, 5);
     }
 
     /**
 
@@ -62,8 +62,8 @@ public void run() {
                     PushForm.getInstance().getPushSuccessCount().setText(String.valueOf(PushData.successRecords));
 
                     // 当前线程发送成功+1
-                    currentThreadSuccessCount.set(currentThreadSuccessCount.get() + 1);
-                    pushThreadTable.setValueAt(currentThreadSuccessCount.get(), tableRow, 2);
+                    successCountLocal.set(successCountLocal.get() + 1);
+                    pushTableLocal.get().setValueAt(successCountLocal.get(), tableRow, 2);
 
                     // 保存发送成功
                     PushData.sendSuccessList.add(msgData);
@@ -79,12 +79,12 @@ public void run() {
                     ConsoleUtil.consoleOnly("发送失败:" + sendResult.getInfo() + ";msgData:" + JSONUtil.toJsonPrettyStr(msgData));
 
                     // 当前线程发送失败+1
-                    currentThreadFailCount.set(currentThreadFailCount.get() + 1);
-                    pushThreadTable.setValueAt(currentThreadFailCount.get(), tableRow, 3);
+                    failCountLocal.set(failCountLocal.get() + 1);
+                    pushTableLocal.get().setValueAt(failCountLocal.get(), tableRow, 3);
                 }
 
                 // 当前线程进度条
-                pushThreadTable.setValueAt((int) ((double) (i + 1) / list.size() * 100), tableRow, 5);
+                pushTableLocal.get().setValueAt((int) ((double) (i + 1) / list.size() * 100), tableRow, 5);
 
                 // 总进度条
                 PushForm.getInstance().getPushTotalProgressBar().setValue(PushData.successRecords.intValue() + PushData.failRecords.intValue());
@@ -95,8 +95,9 @@ public void run() {
         } catch (Exception e) {
             logger.error(ExceptionUtils.getStackTrace(e));
         } finally {
-            currentThreadSuccessCount.remove();
-            currentThreadFailCount.remove();
+            successCountLocal.remove();
+            failCountLocal.remove();
+            pushTableLocal.remove();
         }
 
     }