如何在WPF中实现并行任务？

Question

这只是我试图开始工作的示例测试代码。我知道有更好的方法来报告进度，但我只是想知道为什么这段代码不起作用。我正在读取文件并报告进度，但它会冻结UI，并等待整个任务完成。

private async void runtTasksButton_Click(object sender, RoutedEventArgs e)
{
    List<Task> tasks = new List<Task>();
    var t = Task.Factory.StartNew(() =>
        {
            FileStream fs = File.OpenRead(@"C:\Whatever.txt");
            var totalLength = fs.Length;

            this.Dispatcher.BeginInvoke(new Action(() =>
            {
                progressBar1.Maximum = totalLength;
            }), null);

            using (fs)
            {
                byte[] b = new byte[1024];

                while (fs.Read(b, 0, b.Length) > 0)
                {
                    this.Dispatcher.BeginInvoke(new Action(() =>
                    {
                        progressBar1.Value += 1024;
                    }), null);
                };
            }
        });
    tasks.Add(t);
    await Task.WhenAll(tasks.ToArray());
}

编辑：我知道BackgroundWorker和async/await。但是，我只是想弄清楚这段代码，以便更深入地了解TPL。我确实使用了FileStream.ReadAsync()方法，并且能够在运行时更新ProgressBar：

private void runtTasksButton_Click(object sender, RoutedEventArgs e)
{
    progressTextBox.Text = "";
    label1.Content = "Milliseconds: ";
    progressBar1.Value = 0;
    progressBar2.Value = 0;

    var watch = Stopwatch.StartNew();
    List<Task> tasks = new List<Task>();
    var t1 = Task.Factory.StartNew(() => ReadFile(@"C:\BigFile1.txt", progressBar1));
    var t2 = Task.Factory.StartNew(() => ReadFile(@"C:\BigFile2.txt", progressBar2));

    tasks.Add(t1);
    tasks.Add(t2);

    Task.Factory.ContinueWhenAll(tasks.ToArray(),
        result =>
        {
            var time = watch.ElapsedMilliseconds;
            this.Dispatcher.BeginInvoke(new Action(() =>
                label1.Content += time.ToString()));
        });
}

private async Task ReadFile(string path, ProgressBar progressBar)
{
    FileStream fs = new FileStream(path, FileMode.Open, FileAccess.Read, FileShare.None, 8192, true);
    var totalLength = fs.Length;

    await this.Dispatcher.BeginInvoke(new Action(() =>
    {
        progressBar.Maximum = totalLength;
    }));

    using (fs)
    {
        byte[] b = new byte[8192];
        while (await fs.ReadAsync(b, 0, b.Length) > 0)
        {
            await this.Dispatcher.BeginInvoke(new Action(() =>
            {
                progressBar.Value += 8192;
            }));
        };
    }
}

但是，现在控件进入ContinueWhenAll而不等待文件读取任务完成。但任务会按预期更新相应的ProgressBars。如果有人能给出一些解释，那将是值得赞赏的。

Answer 1

这是Task.Factory.StartNew的经典陷阱。该方法返回一个Task<T>，其中T是回调的返回类型。你的回调是ReadFile，它返回一个Task。因此，你最终会得到一个Task<Task>，而你正在等待外部任务，而你应该等待内部任务。

两种解决方案

1. 推荐的：使用Task.Run而不是Task.Factory.StartNew。这是一般性建议，你不应该使用Task.Factory.StartNew，除非你知道它是正确的解决方案。 Task.Run避免了许多陷阱，例如你遇到的陷阱。 var t1 = Task.Run(() => ReadFile(@"C:\BigFile1.txt", progressBar1));
2. 如果你有合理的理由使用Task.Factory.StartNew，那么你可以在任务上使用.Unwrap()方法，以便能够在内部等待： var t1 = Task.Factory.StartNew(() => ReadFile(@"C:\BigFile1.txt", progressBar1)).Unwrap();