Parallel.For异步等待方法的C#正确模式[关闭]

Question

我想对这种方法提出一些建议。这是一个很好的模式吗？还是会有其他更好的模式？

    public async Task<PortfolioLoans> GetSampleOfPortfolioLoanNumbers(int count = 1)
    {
        var sqlConn = new SqlConnection(this.DataMineConnectionString);
        var pfLoans = new PortfolioLoans();

        var ts = new ThreadSafeList<PortfolioLoan>();

        try
        {
          await Task.Run(() => {
              Parallel.For(0, count, async i =>
              {
               var loans = await sqlConn.QueryAsync("dbo.spGetSampleApplicationIDs", Parameters.Empty, Query.Returns<PortfolioLoan>());
               ts.AddRange(loans);
              });

              pfLoans.Loans.AddRange(ts.Clone());
          });

        }
        catch (Exception ex)
        {
            Debug.WriteLine(ex.Message);
        }

        return pfLoans;
    }

Answer 1

Parallel 类在异步/等待之前发布。它不支持使用async in 作为方法boday。当您使用async 时，它会创建一个匿名的async void 函数，因此它无法判断工作何时完成，并且在您开始的任务完成之前完成。使用 async/await 的更现代的一组类是 TPL Dataflow。

其次，sqlConn 不是线程安全的，你不能同时在多个线程中使用它。你必须为每个线程创建一个新的连接对象。

最后我会把钱放在pfLoans.Loans 是List<T> 或类似的东西上，并且不是线程安全的。您不能从多个线程调用未设计为处理来自多个线程的调用的函数。您必须锁定对 AddRange 的调用，或者将类更改为线程安全的类。

Answer 2

稍微清理一下并添加线程安全性：

   public async Task<PortfolioLoans> GetSampleOfPortfolioLoanNumbers(int count = 1)
   {

        var pfLoans;

        try
        {
           pfLoans = await Task.Run(async () => {
              var sqlConn = new SqlConnection(this.DataMineConnectionString);
              var pls = new Portfolioloans();
              for(var i=0; i<count; i++)
              {
                  var loans = await sqlConn.QueryAsync("dbo.spGetSampleApplicationIDs", Parameters.Empty, Query.Returns<PortfolioLoan>());
                  pls.Loans.AddRange(loans);
              }
             return pls;
      });

    }
    catch (Exception ex)
    {
        Debug.WriteLine(ex.Message);
    }

    return pfLoans;
}

除非这些查询花费的时间太长，否则我不知道我是否会将它们放在 Parallel.For 中

编辑：我错过了 sqlConn.QueryAsync 上的异步，如果担心阻塞，那么你甚至不需要任务，因为 QueryAsync 已经是异步的。

  public async Task<PortfolioLoans> GetSampleOfPortfolioLoanNumbers(int count = 1)
  {
    var pfLoans = new PortfolioLoan();

    try
    {
          var sqlConn = new SqlConnection(this.DataMineConnectionString);
          var pls = new Portfolioloans();
          for(var i=0; i<count; i++)
          {
              var loans = await sqlConn.QueryAsync("dbo.spGetSampleApplicationIDs", Parameters.Empty, Query.Returns<PortfolioLoan>());
              pfLoans.Loans.AddRange(loans);
          }
   }
   catch (Exception ex)
   {
      Debug.WriteLine(ex.Message);
   }

   return pfLoans;
}