diff --git a/ZeroLevel/Services/PartitionStorage/Store.cs b/ZeroLevel/Services/PartitionStorage/Store.cs index 5c94151..a2dabe7 100644 --- a/ZeroLevel/Services/PartitionStorage/Store.cs +++ b/ZeroLevel/Services/PartitionStorage/Store.cs @@ -21,8 +21,6 @@ namespace ZeroLevel.Services.PartitionStorage } } - - public IStorePartitionAccessor CreateAccessor(TMeta info) { return new StorePartitionAccessor(_options, info); @@ -35,8 +33,7 @@ namespace ZeroLevel.Services.PartitionStorage if (searchRequest.PartitionSearchRequests?.Any() ?? false) { var partitionsSearchInfo = searchRequest.PartitionSearchRequests.ToDictionary(r => r.Info, r => r.Keys); - //var options = new ParallelOptions { MaxDegreeOfParallelism = _options.MaxDegreeOfParallelism }; - var options = new ParallelOptions { MaxDegreeOfParallelism = 1 }; + var options = new ParallelOptions { MaxDegreeOfParallelism = _options.MaxDegreeOfParallelism }; await Parallel.ForEachAsync(partitionsSearchInfo, options, async (pair, _) => { using (var accessor = CreateAccessor(pair.Key))