複数のスレッドを1つのタスク用に作成しました。

Question

私は、ASP.NET Webサイトのバックグラウンドタスクシステムの作成を手伝ってくれました。

これはこれはルートTaskから呼び出されTask

Task.Factory.RunNew(RunTimer); 

私のルートです。

private void RunTimer() 
{ 
    while (!cancellationToken.IsCancellationRequested) 
    { 
     var backgroundTasks = _tasks.Values.ToArray(); 
     var tplTasks = new List<Task>(); 
     foreach (var backgroundTask in backgroundTasks) 
     { 
      var newTask = new Task(() => backgroundTask.Run()); 
      tplTasks.Add(newTask); 
      newTask.Start(); 
     } 
     Task.WaitAll(tplTasks.ToArray()); 
     for (int i = 0; i < NumberOfSecondsToWait && 
      !cancellationToken.IsCancellationRequested; i++) 
     { 
      Thread.Sleep(new TimeSpan(0, 0, 1)); 
     } 
    } 
} 

_tasksConcurrentDictionary<string, IBackgroundTask>です。何らかの理由でnewTaskが別のスレッドで2回実行されます。つまり、backgroundTask.Run()が2回呼び出されます。 RunTimerは一度だけ呼び出されます。 NumberOfSecondsToWaitは60です。tplTasksには2つのアイテムしかありません。

誰でもご存知ですか？

Answer 1

これは、lambda（特にnewTaskラムダ）が値ではなく変数にバインドするためです。

あなたが必要です：

... 
foreach (var backgroundTask in backgroundTasks) 
{ 
    var localBackgroundTask = backgroundTask; 
    var newTask = new Task(() => localBackgroundTask.Run()); 
    ... 
} 
...