修复握手超时出队问题 (#659)

Co-authored-by: shenghao <shenghao0219@icloud.com>

Author: shenghao0219

src/SuperSocket.WebSocket.Server/WebSocketServerMiddleware.cs

@@ -85,50 +85,58 @@ private void HandshakePendingQueueCheckingCallback(object state)
         {
             _checkingTimer.Change(Timeout.Infinite, Timeout.Infinite);
 
-            while (true)
+            var openHandshakeTimeTask = Task.Run(() =>
             {
-                WebSocketSession session;
+                while (true)
+                {
+                    WebSocketSession session;
 
-                if (!_openHandshakePendingQueue.TryPeek(out session))
-                    break;
+                    if (!_openHandshakePendingQueue.TryPeek(out session))
+                        break;
 
-                if (session.Handshaked || session.State == SessionState.Closed || (session is IAppSession appSession && appSession.Channel.IsClosed))
-                {
-                    //Handshaked or not connected
+                    if (session.Handshaked || session.State == SessionState.Closed || (session is IAppSession appSession && appSession.Channel.IsClosed))
+                    {
+                        //Handshaked or not connected
+                        _openHandshakePendingQueue.TryDequeue(out session);
+                        continue;
+                    }
+
+                    if (DateTime.Now < session.StartTime.AddSeconds(_options.OpenHandshakeTimeOut))
+                        break;
+
+                    //Timeout, dequeue and then close
                     _openHandshakePendingQueue.TryDequeue(out session);
-                    continue;
+                    session.CloseWithoutHandshake();
                 }
+            });
 
-                if (DateTime.Now < session.StartTime.AddSeconds(_options.OpenHandshakeTimeOut))
-                    break;
+            var closeHandshakeTimeTask = Task.Run(() =>
+            {
+                while (true)
+                {
+                    WebSocketSession session;
 
-                //Timeout, dequeue and then close
-                _openHandshakePendingQueue.TryDequeue(out session);
-                session.CloseWithoutHandshake();
-            }
+                    if (!_closeHandshakePendingQueue.TryPeek(out session))
+                        break;
 
-            while (true)
-            {
-                WebSocketSession session;
+                    if (session.State == SessionState.Closed)
+                    {
+                        //the session has been closed
+                        _closeHandshakePendingQueue.TryDequeue(out session);
+                        continue;
+                    }
 
-                if (!_closeHandshakePendingQueue.TryPeek(out session))
-                    break;
+                    if (DateTime.Now < session.CloseHandshakeStartTime.AddSeconds(_options.CloseHandshakeTimeOut))
+                        break;
 
-                if (session.State == SessionState.Closed)
-                {
-                    //the session has been closed
+                    //Timeout, dequeue and then close
                     _closeHandshakePendingQueue.TryDequeue(out session);
-                    continue;
+                    //Needn't send closing handshake again
+                    session.CloseWithoutHandshake();
                 }
+            });
 
-                if (DateTime.Now < session.CloseHandshakeStartTime.AddSeconds(_options.CloseHandshakeTimeOut))
-                    break;
-
-                //Timeout, dequeue and then close
-                _closeHandshakePendingQueue.TryDequeue(out session);
-                //Needn't send closing handshake again
-                session.CloseWithoutHandshake();
-            }
+            Task.WhenAll(openHandshakeTimeTask, closeHandshakeTimeTask);
 
             _checkingTimer?.Change(_options.CheckingInterval * 1000, _options.CheckingInterval * 1000);
         }