From d94404ecdf08f959dce3667e4bd1c11733a1f69b Mon Sep 17 00:00:00 2001
From: jason wang <jason.wang@aelf.io>
Date: Sun, 30 Jun 2024 15:21:26 +0800
Subject: [PATCH] feat: fix changing non-concurrent collections

---
 .../Sharding/ShardingKeyProvider.cs                            | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/AElf.EntityMapping.Elasticsearch/Sharding/ShardingKeyProvider.cs b/src/AElf.EntityMapping.Elasticsearch/Sharding/ShardingKeyProvider.cs
index 243d8ffe..78e88679 100644
--- a/src/AElf.EntityMapping.Elasticsearch/Sharding/ShardingKeyProvider.cs
+++ b/src/AElf.EntityMapping.Elasticsearch/Sharding/ShardingKeyProvider.cs
@@ -1,3 +1,4 @@
+using System.Collections.Concurrent;
 using System.Linq.Expressions;
 using System.Reflection;
 using AElf.EntityMapping.Elasticsearch.Exceptions;
@@ -18,7 +19,7 @@ public class ShardingKeyProvider<TEntity> : IShardingKeyProvider<TEntity> where
     private readonly ILogger<ShardingKeyProvider<TEntity>> _logger;
 
     private List<ShardingKeyInfo<TEntity>> _shardKeyInfoList;
-    private readonly Dictionary<string, bool> _existIndexShardDictionary = new Dictionary<string, bool>();
+    private readonly ConcurrentDictionary<string, bool> _existIndexShardDictionary = new ConcurrentDictionary<string, bool>();
     private readonly Type _type = typeof(TEntity);
     private readonly string _defaultCollectionName;
     private readonly IShardingCollectionTailProvider<TEntity> _shardingCollectionTailProvider;