如何提高代码性能？ C# 中的多线程或任务？

Question

我有以下两个功能

   void ParserData(List<DataObject> MyObjcets){

        //loop over MyObjects

        List<ResultObject> Results = new List<ResultObject> ();
        foreach(var Obj in MyObjects){
        //do some computation and add it to an instance of ResultObject 
        ResultObject R = new ResultObject();

        Results.Add(R);
        if(Results.count >= 2000){
           //call a function that will insert Results to MYSQL DB 
           InsertDATA(Results);
           //create empty Results list 
           Results = new List<ResultObject> ();
        }
         //
        }

插入函数

void InsertDATA(List<ResultObject> Results){
foreach(var R in Results){
      .....
    //Insert Object to MYSQLDB
    }
}

我正在考虑让这段代码更快，但我不确定最好的方法。我每 2000 年提交一次插入的原因是因为在那之后系统内存不足。 有没有办法在我发送要插入的数据后，我可以在插入我发送的数据时继续做更多的计算，而不是等到插入完成？

任何使此代码更快的建议将不胜感激。

Answer 1

根据您提供的信息 - 您可以使用 async/await 方法作为数据库方法。

使您的数据库插入方法异步

Task SaveResultAsync(ResultObject result)
{
    var query = "INSERT ...."
    using (var conn = new MySqlConnection(connectionString))
    using (var command = new MySqlCommand(conn, query)
    {
        // command.AddParameter for values you want to insert
        await conn.OpenAsync();
        await command.ExecuteNonQueryAsync();
    }
}

然后您可以自己运行每个查询，而无需等待其他查询和结果

async Task ParserData(List<DataObject> MyObjcets)
{
    var tasks = new List<Task>();
    foreach(var Obj in MyObjects)
    {
        //do some computation and add it to an instance of ResultObject 
        ResultObject result = new ResultObject();
        var task = SaveResultAsync(result );

        tasks.Add(task);
    }

    await Task.WhenAll(tasks.ToArray());
}

当然，您也需要将ParseData 方法的签名更改为异步。
更改签名后，async/await 开始像僵尸一样在您的应用程序中传播:)