如何异步处理集合集合

本文关键字：集合 处理 异步 何异步 | 更新日期: 2023-09-27 18:34:33

过去，我通过使用 PLINQ 轻松地将 for 循环变成多任务速度恶魔。

但是，由于处理集合，我遇到了困难。

我可能会自己解决这个问题，但我认为看看其他人也会如何解决这个问题会很有用。

更新：我确信下面的代码存在概念问题，但我无法完全用语言表达它。 如果有人能看到我在说什么，很好，但我会更多地考虑这个问题，并尝试使问题整体上更好(或者如果我意识到这完全是我的错误，请删除它(

这是主要逻辑：

    public static void Execute()
    {
        var service = Locator.Get<ICakeService>();
        using (var db = new Cake.Model.CakeContainer())
        {
            foreach (var campaigns in service.ExportCampaigns())
            {
                // --> THIS LOOP SHOULD BE EXECUTED IN A SEPARATE THREAD
                foreach (var campaign in campaigns)
                {
                    // ... logic to process a campaign ...
                }
            }
        }
    }

以下是服务：

    public IEnumerable<campaign[]> ExportCampaigns()
    {
        campaign[] result = null;
        var service = new exportSoapClient("exportSoap");
        // --> IF I DO A PARALLEL FOREACH HERE THE CLIENT CODE ABOVE 
        // STOPS MAKING SENSE TO ME...
        foreach (var offer in this.ExportOffers())
        {
            var response = service.Campaigns(
                                api_key: this.apiKey,
                                offer_id: offer.offer_id);
            yield return result;
        }
    }

如何异步处理集合集合

并行化的另一个选项是

Parallel.Foreach(service.ExportCampaigns(), campaigns =>
{
    // --> THIS LOOP will be run in multiple threads at the same time

    foreach (var campaign in campaigns)
    {
        // ... logic to process a campaign ...
    }
});

如果内部foreach的工作太少，这可能是比esskar的解决方案更好的选择。

这是一个没有兰巴达斯的版本

public static void Execute(Action<campaign[]> action)
{
    var service = Locator.Get<ICakeService>();
    using (var db = new Cake.Model.CakeContainer())
    {
        Parallel.Foreach(service.ExportCampaigns(), action);
    }
}
//This method will be executed in parallel for each element in the IEnumerable<campaign[]>.
private void ProcessCampaigns(campaign[] campaigns)
{
    foreach (var campaign in campaigns)
    {
        // ... logic to process a campaign ...
    }
}
// Call to Execute looks something like this:
command.Execute(ProcessCampaigns)

使用 System.Threading.Task 中的并行助手

Parallel.Foreach(campaigns, compaign => 
{
    // ... logic to process a campaign ...
});

编辑：这是一个完整的示例

public static void Execute()
{
    var service = Locator.Get<ICakeService>();
    using (var db = new Cake.Model.CakeContainer())
    {
        foreach (var campaigns in service.ExportCampaigns())
        {
            ProcessCampaigns(campaigns);                
        }
    }
}
private void ProcessCampaigns(IEnumerable<Campaign>> campaigns)
{
    Parallel.Foreach(compaigns, ProcessCampaign);
}
private void ProcessCampaign(Campaign campaign)
{
    // ... logic to process a campaign ...
}
相关文章：