如何在一个带有任务的线程中执行循环的每次迭代？

Question

我有一个检查一些数据的方法，我想知道如何在不同的线程中检查这些数据。我正在使用任务和异步/等待模式。

private bool my myCheckMethod(List<long> paramData)
{
     //code that check the information in the list
}


private void mainMethod()
{
    //1.- get data from the data base
    //2.- i group the data from the database in many lists.

    foreach(list<List<long>> iterator in myListOfLists)
    {
          myCheckMethod(itrator);
    }
}

但我希望 myCheckMethod 不是一次只执行一个，而是使用任务同时执行多个。我认为这将花费更少的时间。

但是，我不知道该怎么做。我尝试这样的事情：

private void mainMethod()
{
    //1.- get data from the data base
    //2.- i group the data from the database in many lists.

    string initTime = System.DateTime.String();
    foreach(list<List<long>> iterator in myListOfLists)
    {
          myCheckMethod(itrator);
    }

    string endTime = System.DateTime.String();
}

我想知道何时开始检查以及检查所有列表时的信息。

我尝试这样的事情：

private void mainMethod()
    {
        //1.- get data from the data base
        //2.- i group the data from the database in many lists.

        string startTime = System.DateTime.String();
        foreach(list<List<long>> iterator in myListOfLists)
        {
             TaskEx.Run(() =>
             {
                myCheckMethod(itrator);
             });
        }

        string endTime = System.DateTime.String();
    }

但在这种情况下，开始时间和结束时间是相同的，因为我不等待任务。所以我尝试了另一个选项：

private void mainMethod()
    {
        //1.- get data from the data base
        //2.- i group the data from the database in many lists.

        string startTime = System.DateTime.String();
        foreach(list<List<long>> iterator in myListOfLists)
        {
             TaskEx.Run(() =>
             {
                myCheckMethod(itrator);
             }).wait();
        }

        string endTime = System.DateTime.String();
    }

但在这种情况下，只同时执行一个 myCheckMethod，因为我正在等待完成一个以继续下一次迭代。

那么如何同时执行多个检查方法呢？

Answer 1

var sw = Stopwatch.StartNew();
var pendingTasks =
  myListOfLists
    .Select(iterator => TaskEx.Run(() => myCheckMethod(iterator))).ToArray();
Task.WaitAll(pendingTasks);
var elapsedTime = sw.Elapsed;