[修改]1. 修改消息发送队列的数据结构为链表的方式

Author: AlianBlank

Runtime/Network/Network/NetworkManager.NetworkChannelBase.cs

@@ -25,7 +25,7 @@ public abstract class NetworkChannelBase : INetworkChannel, IDisposable
             private const float DefaultHeartBeatInterval = 30f;
             private const int DefaultMissHeartBeatCountByClose = 10;
 
-            protected readonly Queue<MessageObject> PSendPacketPool;
+            protected readonly GameFrameworkLinkedList<MessageObject> PSendPacketPool;
             protected readonly INetworkChannelHelper PNetworkChannelHelper;
             protected AddressFamily PAddressFamily;
 
@@ -96,7 +96,7 @@ protected bool PActive
             public NetworkChannelBase(string name, INetworkChannelHelper networkChannelHelper, int rpcTimeout)
             {
                 Name = name ?? string.Empty;
-                PSendPacketPool = new Queue<MessageObject>(128);
+                PSendPacketPool = new GameFrameworkLinkedList<MessageObject>();
                 PNetworkChannelHelper = networkChannelHelper;
                 PAddressFamily = AddressFamily.Unknown;
                 PResetHeartBeatElapseSecondsWhenReceivePacket = false;
@@ -117,7 +117,6 @@ public NetworkChannelBase(string name, INetworkChannelHelper networkChannelHelpe
                 NetworkChannelClosed = null;
                 NetworkChannelMissHeartBeat = null;
                 NetworkChannelError = null;
-                NetworkChannelCustomError = null;
 
                 networkChannelHelper.Initialize(this);
             }
@@ -669,7 +668,7 @@ public void Send<T>(T messageObject) where T : MessageObject
 
                 lock (PSendPacketPool)
                 {
-                    PSendPacketPool.Enqueue(messageObject);
+                    PSendPacketPool.AddLast(messageObject);
                 }
             }
 
@@ -740,10 +739,10 @@ protected virtual bool ProcessSend()
                     }
 
 
-                    while (PSendPacketPool.Count > 0)
+                    while (PSendPacketPool.First !=null)
                     {
-                        var messageObject = PSendPacketPool.Dequeue();
-
+                        var messageObject = PSendPacketPool.First.Value;
+                        PSendPacketPool.RemoveFirst();
                         bool serializeResult = false;
                         try
                         {

Runtime/Network/Network/WebSocket/NetworkManager.WebSocketNetworkChannel.cs

@@ -93,11 +93,12 @@ protected override bool ProcessSend()
                         return false;
                     }
 
-                    while (PSendPacketPool.Count > 0)
+                    while (PSendPacketPool.First != null)
                     {
-                        var messageObject = PSendPacketPool.Dequeue();
+                        var messageObject = PSendPacketPool.First.Value;
+                        PSendPacketPool.RemoveFirst();
 
-                        bool serializeResult = false;
+                        bool serializeResult;
                         try
                         {
                             serializeResult = ProcessSendMessage(messageObject);