Parallel.ForEachAsync 需要帮助

Question

好的。因此，我将首先向前道歉，据我所知，关于并行和async有很多问题。但是，即使在搜索之后，我也无法围绕该如何工作。编码是我日复一日地做的事情。

我正在尝试帮助朋友使用Alphavantage API收集一些历史性的库存数据。

我在收集数据并将其保存到数据库时没有问题，但是要花20年的每日价格可能需要很长时间。因此，为了避免GUI冻结，我使其成为异步功能。但是，考虑到需要拉出多少数据，需要并行完成。我不确定有多少平行事件，但长期目标是在应用程序中将计时器置于时间间隔中，并调用batchupdateStockhistoryAsyAsyAsyAsyAsyAsync方法，并通过一个值来通过多少股票来拉动然后在此批处理中更新该功能，然后将出现，查询数据库并获取具有最古老更新的列表5。

目前，我将所有这些简单地剥离了这个问题，只是创建了5个迭代的手动列表。对于列表中的每个股票，它调用另一个函数PullandWriteHistoricDailyData（item），它可以实际联系到Alphavantage并更新DB。

在这个冗长的信息之后，我的问题是，最好的方法是触发pullandwritehistoricdailydataa（）的多个并发线程？

我想我还需要使用maxdegreofparallelism来弄清楚什么最有效，但我甚至还没有走那么远。我相信我想使用Parallel.ForeachAsync？但是只是不确定如何将它们全部拉在一起。

任何帮助将不胜

感激

    public async Task BatchUpdateStockHistoryAsync()
    {
        List<string> list = new List<string>();

        list.Add("AAPL");
        list.Add("F");
        list.Add("MSFT");
        list.Add("COKE");
        list.Add("IAG");

        foreach(string item in list)
        {
            await Task.Run(() => PullAndWriteHistoricDailyData(item));
        }

        return completed;
    }

Answer 1

编辑我最初错误地阅读了 Task.WhenAll 与 Parallel.ForEach 的内容。根据 Theodore Zoulias 的回答阅读有关 Parallel.ForEachAsync 的更多信息后：is-parallel-foreachasync- a-replacement-to-a-plain-for-loop-append-to-task-list，并基于您想要查看每个任务的结果的假设要通过调用 Parallel.ForEachAsync 接收单个任务，那么我建议更改为使用以下内容：

您可以切换到使用 List 并使用 < code>await Task.WhenAll() 并跳过 Parallel.ForEachAsync，如下所示：

 List<Task> myupdatetasks = new List<Task>();

 foreach(string item in list)
 {
     myupdatetasks.Add(Task.Run(() => PullAndWriteHistoricDailyData(item)));
 }

 await Task.WhenAll(myupdatetasks).ConfigureAwait(false);

如果 PullAndWriteHistoricDailyData() 已经是async 方法，您不需要使用 Task.Run，

 List<Task> myupdatetasks = new List<Task>();

 foreach(string item in list)
 {
     myupdatetasks.Add(PullAndWriteHistoricDailyData(item));
 }

 await Task.WhenAll(myupdatetasks).ConfigureAwait(false);

如果您是 ，您可以执行与上面相同的操作，减去 Task.Run打算使用 Parallel.ForEachAsync，这篇文章很好地解释了它：parallelforeachasync-in-net-6