From 6c349aa128d8c3ed14fa5f3953d94b8dede65de4 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期六, 17 八月 2024 10:27:41 +0800
Subject: [PATCH] 实时推送
---
src/main/java/com/whyc/webSocket/BattSocket.java | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/BattSocket.java b/src/main/java/com/whyc/webSocket/BattSocket.java
index fdb7c40..0ff4896 100644
--- a/src/main/java/com/whyc/webSocket/BattSocket.java
+++ b/src/main/java/com/whyc/webSocket/BattSocket.java
@@ -83,13 +83,13 @@
@OnMessage
public void onMessage(Session session, String message) {
int binfId=Integer.valueOf(message);
- thread = new Thread("Thread_RealTime") {
+ thread = new Thread("Thread_BattSocket") {
@Override
public void run() {
+ Map<String, Object> res = new HashMap<>();
while (runFlag && !isInterrupted()) {
Thread thread = currentThread();
threadFlagMap.put(thread.getId(), true);
- Map<String, Object> res = new HashMap<>();
try {
ThreadPoolExecutor poolExecutor = ThreadPoolExecutorFactory.getPoolExecutor();
CountDownLatch latch = new CountDownLatch(4);
--
Gitblit v1.9.1