ciro_xu/iotgateway
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

并行启动采集线程

Browse Source
This commit is contained in:
iioter 2023-10-21 22:13:01 +08:00
parent e9ee682f37
commit 68f217fa3f
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
Plugins/Plugin/DeviceService.cs
View File

@ -40,10 +40,7 @@ namespace Plugin
.Include(x => x.Parent).Include(x => x.Driver).Include(x => x.DeviceConfigs) .Include(x => x.Parent).Include(x => x.Driver).Include(x => x.DeviceConfigs)
.Include(x => x.DeviceVariables).AsNoTracking().ToList(); .Include(x => x.DeviceVariables).AsNoTracking().ToList();
_logger.LogInformation($"Loaded Devices Count:{devices.Count()}"); _logger.LogInformation($"Loaded Devices Count:{devices.Count()}");
foreach (var device in devices) Parallel.ForEach(devices, CreateDeviceThread);
{
CreateDeviceThread(device);
}
} }
} }
catch (Exception ex) catch (Exception ex)