yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix 并发线程数由系统处理

Browse Source
This commit is contained in:
liguoyang
2024-11-28 16:03:42 +08:00
parent 8f5f651dde
commit c653c8d453
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Src/Dlhis.Basic/Device/Services/Implements/DevicePermissionService.cs
View File

@@ -219,7 +219,7 @@ public class DevicePermissionService : IDevicePermissionService
var waitAddTasks = new ConcurrentBag<DeviceTaskEntity>(); var waitAddTasks = new ConcurrentBag<DeviceTaskEntity>();
var waitDeleteTasks = new ConcurrentBag<DeviceTaskEntity>(); var waitDeleteTasks = new ConcurrentBag<DeviceTaskEntity>();
Parallel.ForEach(userNos, new ParallelOptions { MaxDegreeOfParallelism = 100 }, userNo => Parallel.ForEach(userNos, userNo =>
{ {
before.TryGetValue(userNo, out var beforeTenantDeviceCodes); before.TryGetValue(userNo, out var beforeTenantDeviceCodes);
beforeTenantDeviceCodes ??= new List<UserTenantDeviceCodeDto>(); beforeTenantDeviceCodes ??= new List<UserTenantDeviceCodeDto>();
@@ -622,11 +622,7 @@ public class DevicePermissionService : IDevicePermissionService
var departments = await _dbContext.Queryable<DepartmentEntity>().ToListAsync(); var departments = await _dbContext.Queryable<DepartmentEntity>().ToListAsync();
var result = new ConcurrentDictionary<string, List<UserTenantDeviceCodeDto>>(); var result = new ConcurrentDictionary<string, List<UserTenantDeviceCodeDto>>();
var parallelOptions = new ParallelOptions Parallel.ForEach(gainfos, gainfo =>
{
MaxDegreeOfParallelism = 100,
};
Parallel.ForEach(gainfos, parallelOptions, gainfo =>
{ {
var gainfoDto = new GainfoDto var gainfoDto = new GainfoDto
{ {