luosheng/Modbus.Net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
parallelbgls
2016-09-20 11:04:54 +08:00
parent 55f842f9b1
commit fc693ebd8a
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
Modbus.Net/Modbus.Net/TaskManager.cs
View File

@@ -512,14 +512,14 @@ namespace Modbus.Net
/// <returns></returns> /// <returns></returns>
private async Task MaintainTasks2Async() private async Task MaintainTasks2Async()
{ {
var tasks = new List<Task>();
HashSet<BaseMachine> saveMachines = new HashSet<BaseMachine>();
lock (_unlinkedMachines)
{
saveMachines.UnionWith(_unlinkedMachines);
}
try try
{ {
var tasks = new List<Task>();
HashSet<BaseMachine> saveMachines = new HashSet<BaseMachine>();
lock (_unlinkedMachines)
{
saveMachines.UnionWith(_unlinkedMachines);
}
foreach (var machine in saveMachines) foreach (var machine in saveMachines)
{ {
CancellationTokenSource cts = new CancellationTokenSource(); CancellationTokenSource cts = new CancellationTokenSource();
@@ -527,7 +527,7 @@ namespace Modbus.Net
var task = _tasks.StartNew(() => RunTask(machine).WithCancellation(cts.Token)); var task = _tasks.StartNew(() => RunTask(machine).WithCancellation(cts.Token));
tasks.Add(task); tasks.Add(task);
} }
await Task.WhenAll(); await Task.WhenAll(tasks);
} }
catch catch
{ {