From cadb69f4b97ed27c46890319904789705431fd5d Mon Sep 17 00:00:00 2001
From: ChenYi <296215406@outlook.com>
Date: Thu, 17 Apr 2025 08:29:32 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B0=8610=E4=B8=87Redis=E7=9A=84Hash=E8=A1=A8?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E8=AF=BB=E5=8F=96=E4=BC=98=E5=8C=96=E5=88=B0?=
 =?UTF-8?q?13=E7=A7=92=E4=BB=A5=E5=86=85=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../RedisDataCache/RedisDataCacheService.cs   | 20 +++++++------------
 1 file changed, 7 insertions(+), 13 deletions(-)

diff --git a/src/JiShe.CollectBus.Application/RedisDataCache/RedisDataCacheService.cs b/src/JiShe.CollectBus.Application/RedisDataCache/RedisDataCacheService.cs
index e846ada..67a435d 100644
--- a/src/JiShe.CollectBus.Application/RedisDataCache/RedisDataCacheService.cs
+++ b/src/JiShe.CollectBus.Application/RedisDataCache/RedisDataCacheService.cs
@@ -492,20 +492,14 @@ return {#result_members, result_members, result_scores, hash_data}";
             var scores = ((object[])scriptResult[2]).Cast<string>().Select(decimal.Parse).ToList();
             var hashData = ((object[])scriptResult[3]).Cast<string>().ToList();
 
-            var validItems = members.Select((m, i) =>
+            var validItems = members.AsParallel()
+            .Select((m, i) =>
             {
-                try
-                {
-                    return !string.IsNullOrEmpty(hashData[i])
-                        ? BusJsonSerializer.Deserialize<T>(hashData[i])
-                        : null;
-                }
-                catch (Exception ex)
-                {
-                    _logger.LogError($"反序列化失败: {m} - {ex.Message}");
-                    return null;
-                }
-            }).Where(x => x != null).ToList();
+                try { return BusJsonSerializer.Deserialize<T>(hashData[i]); }
+                catch { return null; }
+            })
+            .Where(x => x != null)
+            .ToList();
 
             var hasNext = validItems.Count > pageSize;
             var actualItems = hasNext ? validItems.Take(pageSize) : validItems;