将线程安全方法添加到 listBox

Question

我有一个线程，想用进度更新一个列表，但表单控件不是线程安全的。所以我学习了如何用这个article解决。

问题是来源更多，每个来源都有自己的列表来显示进度。那么如何让每个列表框都有自己的ThreadSafeSetText() 方法来清理代码呢？

delegate void SetTextCallback(string text);
private async void btnRun_Click(object sender, EventArgs e)
{
   await Task.Run(() =>
   {
      importSource1();
   });

   //await Task.Run(() =>
   //{
   //   importSource2();
   //});
}

private void importSource1()
{
   // db stuff in a Parallel.For

   SetText("Result");
}

private void SetText(string text)
{
   // InvokeRequired required compares the thread ID of the
   // calling thread to the thread ID of the creating thread.
   // If these threads are different, it returns true.
   if (this.lstImportSource1.InvokeRequired)
   {
      SetTextCallback d = new SetTextCallback(SetText);
      this.Invoke(d, new object[] { text });
   }
   else
   {
      this.lstImportSource1.Items.Insert(0, text);
   }
}

Answer 1

基于ImportSource 是一种执行数据库过程的方法的评论，我的建议使用async-await 方法。
Async-await 旨在在您的代码执行“触及”外部操作时更有效地使用资源资源（数据库、文件系统、Web API 等）。

因为在执行数据库查询期间（例如）您的方法“什么都不做”，它只发送请求并等待响应。创建“什么都不做”被视为浪费资源的新线程。

async-await 操作将在一个线程（大部分时间）上执行，您可以在其中简单地使用 UI 控件。

您可以为每个过程创建自己的异步方法

public async Task ExecuteProcedure1Async()
{
    using (var connection = new SqlConnection("connection string"))
    using (var command = new SqlCommand("dbo.sqlProcedure1", connection))
    {
        command.CommandType = CommandType.StoredProcedure;

        // Here execution will send request to the database
        // and be returned to the caller of this method         
        await connection.OpenAsync();
        // Continue after OpenAsync is completes and
        // Here execution will again will be returned to the caller 
        await command.ExecuteCommandAsync();
        // Continues after ExecuteCommandAsync is completed
    }      
}

可以为另一个存储过程创建类似的方法

以下所有程序将“几乎”同时执行。
因为我们会发送请求而不等待响应 并且仅在所有程序完成后等待

private async Task ImportSource1Async()
{
    // Because asynchronoud method returns Task
    // We can create collection of tasks and "await" them all
    // after they have been started
    var tasks = new[] 
    {
        ExecuteProcedure1Async(),
        ExecuteProcedure2Async(),
        ExecuteProcedure3Async()
    };

    await Task.WhenAll(tasks);
}

然后您可以在button_click 事件处理程序中将所有ImportSourceAsync 方法组合在一起并使用UI 控件。

private async void btnRun_Click(object sender, EventArgs e)
{
    await ImportSource1Async();
    lstImportSource1.Items.Insert(0, "Import source 1 complete");

    await ImportSource2Async();
    lstImportSource1.Items.Insert(0, "Import source 2 complete");

    await ImportSource3Async();
    lstImportSource1.Items.Insert(0, "Import source 3 complete");
}