refactor(web): 将 WebBinaryData 改用引用池模式

WebBinaryData 改为工厂方法 Create() + Clear() 模式，
WebManager.Binary 中 Dispose() 替换为 ReferencePool.Release()。

GameFrameX/com.gameframex.unity#5

Author: AlianBlank

Runtime/Web/WebManager.Binary.cs

@@ -15,7 +15,7 @@ namespace GameFrameX.Web.Runtime
     /// <summary>
     /// Web请求管理器的ProtoBuf部分实现
     /// </summary>
-    public partial class WebManager : GameFrameworkModule, IWebManager
+    public partial class WebManager
     {
         /// <summary>
         /// 等待处理的Binary请求队列
@@ -63,15 +63,15 @@ private void ShutdownBinary()
             while (m_WaitingBinaryQueue.Count > 0)
             {
                 var webData = m_WaitingBinaryQueue.Dequeue();
-                webData.Dispose();
+                ReferencePool.Release(webData);
             }
 
             m_WaitingBinaryQueue.Clear();
             while (m_SendingBinaryList.Count > 0)
             {
                 var webData = m_SendingBinaryList[0];
                 m_SendingBinaryList.RemoveAt(0);
-                webData.Dispose();
+                ReferencePool.Release(webData);
             }
 
             m_SendingBinaryList.Clear();
@@ -119,10 +119,12 @@ private async void MakeBinaryBytesRequest(WebBinaryData webData)
                 if (unityWebRequest.isNetworkError || unityWebRequest.isHttpError || unityWebRequest.error != null)
                 {
                     webData.Task.TrySetException(new Exception(unityWebRequest.error));
+                    ReferencePool.Release(webData);
                     return;
                 }
 
                 webData.Task.SetResult(new WebBufferResult(webData.UserData, unityWebRequest.downloadHandler.data));
+                ReferencePool.Release(webData);
             };
 #else
             try
@@ -189,6 +191,7 @@ private async void MakeBinaryBytesRequest(WebBinaryData webData)
             finally
             {
                 m_SendingBinaryList.Remove(webData);
+                ReferencePool.Release(webData);
             }
 
 #endif
@@ -210,7 +213,7 @@ public Task<WebBufferResult> PostToBytes(string url, byte[] from, Dictionary<str
             queryString = MergeQueryString(queryString);
             header = MergeHeader(header);
             url = UrlHandler(url, queryString);
-            var webData = new WebBinaryData(url, header, from, uniTaskCompletionSource, userData);
+            var webData = WebBinaryData.Create(url, header, from, uniTaskCompletionSource, userData);
             m_SendingBinaryList.Add(webData);
             MakeBinaryBytesRequest(webData);
             return uniTaskCompletionSource.Task;

Runtime/Web/WebManager.WebBinaryData.cs

@@ -11,36 +11,77 @@ public partial class WebManager
         /// </summary>
         private sealed class WebBinaryData : WebData
         {
+            private Dictionary<string, string> m_Header;
+
             /// <summary>
             /// 获取请求任务的完成源，用于异步操作的控制和结果返回
             /// </summary>
-            public readonly TaskCompletionSource<WebBufferResult> Task;
+            public TaskCompletionSource<WebBufferResult> Task { get; private set; }
 
             /// <summary>
-            /// 获取要发送的Protocol Buffer序列化后的字节数组数据
+            /// 获取要发送的字节数组数据
             /// </summary>
-            public readonly byte[] SendData;
+            public byte[] SendData { get; private set; }
 
             /// <summary>
             /// 获取请求头信息
             /// </summary>
-            public readonly Dictionary<string, string> Header;
+            public Dictionary<string, string> Header { get { return m_Header; } }
+
+            /// <summary>
+            /// 无参构造函数（ReferencePool 需要new约束）
+            /// </summary>
+            public WebBinaryData() { }
 
             /// <summary>
-            /// 初始化Web Binary请求数据
+            /// 创建Web Binary请求数据
             /// </summary>
-            /// <param name="url">请求URL</param>
-            /// <param name="header">请求头信息</param>
-            /// <param name="sendData">要发送的Binary序列化数据</param>
-            /// <param name="task">请求任务的完成源</param>
-            /// <param name="userData">用户自定义数据</param>
-            public WebBinaryData(string url, Dictionary<string, string> header, byte[] sendData, TaskCompletionSource<WebBufferResult> task, object userData) : base(false, url, userData)
+            public static WebBinaryData Create(string url, Dictionary<string, string> header, byte[] sendData, TaskCompletionSource<WebBufferResult> task, object userData)
             {
-                task.CheckNull(nameof(task));
-                SendData = sendData;
-                Task = task;
-                Header = header;
+                var data = ReferencePool.Acquire<WebBinaryData>();
+                data.URL = url;
+                data.IsGet = false;
+                data.UserData = userData;
+                data.Task = task;
+                data.SendData = sendData;
+
+                if (header != null && header.Count > 0)
+                {
+                    if (data.m_Header == null)
+                    {
+                        data.m_Header = new Dictionary<string, string>();
+                    }
+                    else
+                    {
+                        data.m_Header.Clear();
+                    }
+
+                    foreach (var kv in header)
+                    {
+                        data.m_Header[kv.Key] = kv.Value;
+                    }
+                }
+
+                return data;
+            }
+
+            public override void Clear()
+            {
+                if (Task != null)
+                {
+                    Task.TrySetCanceled();
+                    Task = null;
+                }
+
+                SendData = null;
+
+                if (m_Header != null)
+                {
+                    m_Header.Clear();
+                }
+
+                base.Clear();
             }
         }
     }
-}
+}