在 C 语言中并行运行特定任务的正确方法#-解网

问：

我有一个运行并执行某些方法的 Windows C# BackgroundService 进程。我想利用系统上的多线程运行此方法以尽可能多地进行处理。该方法包含一个数据库事务，并在其中根据该事务执行一些文件 I/O。我不需要任务的结果，只需要尽快运行它们。DoWork

目前，我让它运行如下例所示。这有效，我确实看到了性能的提高，但这似乎不是正确的方法。我也看到了使用的能力，但我看到了与 .我想做的是不断利用可用的线程来执行。我这样做是否正确，或者有更好的方法可以做到这一点？Task.RunWaitAllParallel.ForDoWork

编辑：现在，除了对 .DoWork

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    _logger.LogInformation(
        "Consume Scoped Service Hosted Service running.");

    Parallel.For(0, 8, task => {
        await DoWork(stoppingToken);
    });

    await Task.Delay(Timeout.Infinite, stoppingToken);
}

private async Task DoWork(CancellationToken stoppingToken)
{
    _logger.LogInformation(
        "Consume Scoped Service Hosted Service is working.");

    using (var transactionScope = new TransactionScope())      
    {      
       try      
       {      
          using (SqlConnection connection = new SqlConnection(connectionString))      
          {      
                connection.Open();      
                // get initial query which gets the row with data needed
                // to perform the file I/O and build request
                var query = "SELECT TOP(1) FROM MyTable" +
                    " WITH (readpast, rowlock, updlock)";
                var row = connection.Query<MyType>(query);

                // based on query, perform file i/o
                var file = File.ReadAllText(row.FileName);
                var data = JsonSerializer.Deserialize<MyData>(file);

                var item = new MyObject() { Id = data.Id, Name = data.Name };
                
                // call a WCF web service using item object, the web service
                // has no asynchronous methods
                service.SendRequest(item);

                // update the transaction and then close
                var updateQuery = "UPDATE MyTable SET Status = @Status WHERE Id = @Id";
                connection.Execute<MyType>(updateQuery);
                transactionScope.Complete();                 
          }           
       }      
       catch(Exception ex)      
       {      
          // Log error      
          transactionScope.Dispose();      
       }      
    }    

}

C# 多线程异步处理任务并行库

@StephenCleary 它已经没有抓取相同的项目，请参阅readpast、rowlock和updlock提示。该功能按我想要的方式工作，我想确认是否有更好的方法来并行运行多个任务。基本上，我希望运行多个线程或任务来执行工作，以便我可以同时处理更多文件。就循环而言，一个线程是否应该处理多个项目？

答：

1赞 Theodor Zoulias 3/8/2023 #1

由于面向 .NET 7，因此可以使用 .NET 6 API Parallel.ForEachAsync：

ParallelOptions options = new()
{
    MaxDegreeOfParallelism = 2,
    CancellationToken = stoppingToken,
};

await Parallel.ForEachAsync(Enumerable.Range(0, 8), options, async (_, ct) =>
{
    await DoWork(ct);
});

您可以尝试使用 MaxDegreeOfParallelism 选项，直到找到手头任务的最佳值。从一个小值开始，逐渐增加它，直到性能停止提高。

在 C 语言中并行运行特定任务的正确方法#

Proper way to run a specific task in parallel in C#

评论

评论