[*] 优化线程

taoyao-signal/src/main/java/com/acgist/taoyao/signal/client/ClientSessionManager.java

@@ -147,6 +147,7 @@ public class ClientSessionManager {
 	 */
 	public void close(AutoCloseable instance) {
 		final ClientSession session = this.session(instance);
+		// TODO：如果出现异常可以提前移除
 		try {
 			if(session != null) {
 				session.close();

taoyao-signal/src/main/java/com/acgist/taoyao/signal/client/websocket/WebSocketSession.java

@@ -24,14 +24,16 @@ public class WebSocketSession extends ClientSessionAdapter<Session> {
 
 	@Override
 	public void push(Message message) {
-		try {
-			if(this.instance.isOpen()) {
-				this.instance.getBasicRemote().sendText(message.toString());
-			} else {
-				log.error("会话已经关闭：{}", this.instance);
+		synchronized (this.instance) {
+			try {
+				if(this.instance.isOpen()) {
+					this.instance.getBasicRemote().sendText(message.toString());
+				} else {
+					log.error("会话已经关闭：{}", this.instance);
+				}
+			} catch (Exception e) {
+				log.error("WebSocket发送消息异常：{}", message, e);
 			}
-		} catch (Exception e) {
-			log.error("WebSocket发送消息异常：{}", message, e);
 		}
 	}
 

taoyao-signal/src/main/java/com/acgist/taoyao/signal/client/websocket/WebSocketSignal.java

@@ -70,14 +70,16 @@ public class WebSocketSignal {
 	 * @param message 消息
 	 */
 	private void push(Session session, Message message) {
-		try {
-			if(session.isOpen()) {
-				session.getBasicRemote().sendText(message.toString());
-			} else {
-				log.error("会话已经关闭：{}", session);
+		synchronized (session) {
+			try {
+				if(session.isOpen()) {
+					session.getBasicRemote().sendText(message.toString());
+				} else {
+					log.error("会话已经关闭：{}", session);
+				}
+			} catch (Exception e) {
+				log.error("推送消息异常：{}", message, e);
 			}
-		} catch (Exception e) {
-			log.error("推送消息异常：{}", message, e);
 		}
 	}