//package com.iailab.module.event.ws;
|
//
|
//import java.util.concurrent.ExecutorService;
|
//import java.util.concurrent.Executors;
|
//
|
//public enum ReconnectThreadEnum {
|
//
|
// WebSocketInstance(){
|
// @Override
|
// public void reconnectWs(EventWebSocketClient demoWebSocketClient) {
|
// cachedThreadPool.execute(new Runnable() {
|
// @Override
|
// public void run() {
|
// try {
|
// //重连间隔一秒
|
// Thread.sleep(10000000);
|
// System.out.println("重新连接");
|
// } catch (InterruptedException e) {
|
// e.printStackTrace();
|
// }
|
// demoWebSocketClient.reconnect();
|
// }
|
// });
|
// }
|
// };
|
//
|
// private static final ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
|
//
|
// public abstract void reconnectWs(EventWebSocketClient demoWebSocketClient);
|
//
|
// public static ReconnectThreadEnum getInstance(){
|
// return WebSocketInstance;
|
// }
|
//}
|