c# - 等待多个独立任务的最佳方法/实践是什么?

标签 c# async-await asp.net-core-webapi

var contractSchemaTask = contractSchemaRepository.GetByContractIdAsync(data.Id);
var sectionsTask = sectionRepository.GetAllByContractIdAsync(id);
var latestContractIdTask = contractRepository
    .GetLatestContractIdByFolderIdAsync(data.FolderId.Value);
List<Task> allTasks = new List<Task>()
    { contractSchemaTask, sectionsTask, latestContractIdTask };
while (allTasks.Any())
{
    Task finished = await Task.WhenAny(allTasks);
    if (finished == contractSchemaTask)
    {
        var contractSchema = await contractSchemaTask;
        result.ReturnData.IsSchedules = contractSchema.Count > 0 ? true : false;
    }
    else if (finished == sectionsTask)
    {
        List<Section> sections = await sectionsTask;

        List<TextValueVM> SectionTabList = sections.Count > 0 ? sections
            .OrderBy(a => a.SectionNumber)
            .Select(a => new TextValueVM()
                { Text = a.ToString(), Value = a.Id.ToString() })
            .ToList() : new List<TextValueVM>();

        bool IsSectionsLinked = false;
        int linkSectionCount = sections
            .Where(x => x.LinkSectionId != null && x.LinkSectionId != Guid.Empty)
            .ToList()
            .Count();
        if (linkSectionCount == 0 && sections.Count > 0)
        {
            List<Guid> sectionIds = sections.Select(x => x.Id.Value).ToList();
            List<Section> currentContractLinkSections = await sectionRepository
                .GetSectionsByLinkSectionIdAsync(sectionIds);
            if (currentContractLinkSections.Count > 0)
            {
                IsSectionsLinked = true;
            }
        }
        else if (linkSectionCount > 0)
        {
            IsSectionsLinked = true;
        }
        result.ReturnData.SectionTabList = SectionTabList;
        result.ReturnData.IsSectionsLinked = IsSectionsLinked;
    }
    else if (finished == latestContractIdTask)
    {
        Guid LatestContractId = await latestContractIdTask;
        result.ReturnData.isLatestContract
            = (data.Id == LatestContractId) ? true : false;
    }
    allTasks.Remove(finished);
}

我正在开发一个 asp.net core 3.0 WebAPI 项目。上面是我使用 while 循环处理的独立任务的示例代码。在异步编程中是否有更好或更有效的方法来处理独立任务?

P.S:所有 3 个任务都是独立的,并且响应时间可能会有所不同,具体取决于从数据库获取的记录数量。

最佳答案

你应该这样做:

public Task Main()
{
    var result = new Result();
    return Task.WhenAll(TaskOne(result), TaskTwo(result), TaskThree(result));
}

    private async Task TaskOne(Result result)
    {
        var contractSchema = await contractSchemaRepository.GetByContractIdAsync(data.Id);
        //your logic for task1, set related result properties
    }

    private async Task TaskTwo(Result result)
    {
        var sections = await sectionRepository.GetAllByContractIdAsync(id);
        //your logic for task2, set related result properties
    }

    private async Task TaskThree(Result result)
    {
        var latestContractId = await contractRepository.GetLatestContractIdByFolderIdAsync(data.FolderId.Value);
        //your logic for Task3, set related result properties
    }

Result 类应该实现为线程安全的,因为任务可以同时执行。如果您只是在每个方法中设置不同的属性应该没问题。

关于c# - 等待多个独立任务的最佳方法/实践是什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59154282/

相关文章:

c# - 使用 LINQ 将 XML 数据插入现有 XML

javascript - 将回调传递给异步函数甚至再次包装它是否正常?

c# - 触发并忘记异步等待调用

javascript - ASP.NET REST POST - JavaScript (jQuery) 在 POST 中发送正文

c# - 如何在生产环境中的Asp.Net Core Web API中禁用400错误请求消息正文?

c# - 测试过程。开始?

c# - IEnumerable 问题 : Best performance?

c# - Xamarin Forms 选择器确定或取消按钮按下检测

c# - 何时同时运行异步函数?

azure - 如何调试承载错误="invalid_token"