仅在其他线程上的作业终止后才调用方法？

Question

在我的应用程序中，我有两种从 csv 加载数据的方法。这些方法是loadData() 和loadOtherData()。我想并行运行它们，所以我有两个线程来运行它们。

loadData() 方法也填充一个数据网格视图，而loadOtherData() 方法加载的数据存储在字典myDictionary 中。

数据加载完成后（所以两个线程中运行的方法都完成了）我想调用另一个方法updateGrids()，它以myDictionary为参数。

要使updateGrids() 正常运行，loadData() 和loadOtherData() 必须已成功运行，否则该方法没有可处理的数据。

只有当其他方法在其他线程中终止时，我才能调用方法updateGrids()？

结构如下：

    private void loadData_Click_1(object sender, EventArgs e)
    {
        ThreadStart thread1Start = new ThreadStart(loadData); // load data and fill the first datagridview
        ThreadStart thread2Start = new ThreadStart(loadOtherData); // load data and fill myDictionary
        Thread t1 = new Thread(thread1Start);
        Thread t2 = new Thread(thread2Start);
        t1.Start(); 
        t2.Start();

        updateGrids(myDictionary); // call this method to update remaining datagridviews
    }


    private void updateGrids(Dictionary<string, double> myDictionary)
    {
        // update the remaining datagridviews by using 
        // information in the first datagridview and in myDictionary
    }

但如果我运行它，我会在updateGrids() 时收到错误，因为它没有可使用的数据。如何轻松更改代码以使其正常工作？

Answer 1

启动线程后，您希望等到它们完成。所以添加这几行代码：

t1.Join();
t2.Join();

Join 将导致当前线程休眠，直到正在加入的线程完成。

基于 cmets，我假设这是 WinForms。在这种情况下，Join 将阻塞 UI 线程。您可以创建第三个线程来加入其他两个线程，然后调用 Invoke 来调用您的更新方法。

由于您使用的是 .Net 4.5，因此您可以使用 Async / Await；将async 修饰符添加到您的单击方法事件处理程序中，并直接使用任务而不是线程和await 它们。其他答案涵盖了这一点，您也可以查看blog 了解其他详细信息。

Answer 2

您可以使用async/await 来等待这两个任务而不会阻塞 UI

async private void loadData_Click_1(object sender, EventArgs e)
{
    await Task.WhenAll(Task.Run(() => loadData()), 
                       Task.Run(() => loadOtherData()));

    updateGrids(myDictionary); 
}

Answer 3

您可以直接停止使用 ThreadStart 对象并改用任务 - 让它们从您的 loadData 和 loadOtherData 方法返回。

您有两种选择：

如果您使用的是 .NET 4.0，请使用 Task.WaitAll

或（更可取）....

在 .NET 4.5 及更高版本中使 loadData 和 loadOtherData 异步（或在 .NET 4.0 中使用异步 BCL 包）。当您调用方法时，您可以缓存它们返回的 Task 对象并等待对 Task.WhenAll 的调用

public async Task LoadData(){ 

}

public async Task LoadOtherData() {

}

private async void loadData_Click_1(object sender, EventArgs e)
{
    var loadDataTask = LoadData();
    var loadOtherDataTask = LoadOtherData();
    await Task.WhenAll(loadDataTask, loadOtherDataTask);

    updateGrids(myDictionary);
}