实时推送

whyclxw

2024-08-17 6c349aa128d8c3ed14fa5f3953d94b8dede65de4

实时推送

 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);