| | |
| | | |
| | | private static final int executeTime = 5000; |
| | | |
| | | private static boolean exit=false; |
| | | private volatile boolean runFlag=true; |
| | | |
| | | private static Map<String,Thread> threadMap = new HashMap<>(); |
| | | private volatile Map<String,Thread> threadMap = new HashMap<>(); |
| | | |
| | | private volatile Map<Long,Boolean> threadFlagMap = new HashMap<>(); |
| | | |
| | |
| | | public void onMessage(Session session, String uId){ |
| | | thread = new Thread("Thread_homePage") { |
| | | public void run() { |
| | | while (true) { |
| | | while (runFlag && !isInterrupted()) { |
| | | Thread thread = currentThread(); |
| | | threadFlagMap.put(thread.getId(),true); |
| | | try { |
| | |
| | | @OnClose |
| | | public void onClose(CloseReason closeReason){ |
| | | System.err.println("closeReason = " + closeReason); |
| | | runFlag = false; |
| | | if (thread != null && thread.isAlive()) { |
| | | thread.interrupt(); |
| | | } |
| | | threadMap.remove(session.getId()); |
| | | } |
| | | |
| | | @OnError |
| | |
| | | if (thread != null && thread.isAlive()) { |
| | | thread.interrupt(); |
| | | } |
| | | threadMap.remove(session.getId()); |
| | | } |
| | | } |