我怎样才能使应用程序保持响应，而线程在后台工作？

Question

我有一个简单的应用程序，它会告诉我一个范围内的素数数量：

    private void btnMultiThread_Click(object sender, RoutedEventArgs e)
    {
        var numbers = Enumerable.Range(2, range - 1);
        var totalPrimes = numbers
            .AsParallel()
            .Where(n => Enumerable.Range(2, (int)Math.Sqrt(n) - 1).All(i => n % i != 0))
            .Count();
        MessageBox.Show(totalPrimes.ToString());
    }

问题是，当整个事情都在计算时，wpf 应用程序仍然没有响应：例如，我单击的按钮仍然被按下，应用程序窗口无法移动甚至关闭。

我该怎么做才能解决这个问题？ 谢谢

Answer 1

这与多线程本身无关。 Parallel 和 PLINQ 使用多个线程包括当前线程并行处理数据。如果您想避免阻塞，则必须在后台任务中执行 PLINQ 查询，例如使用 Task.Run：

private async void btnMultiThread_Click(object sender, RoutedEventArgs e)
{
    var numbers = Enumerable.Range(2, range - 1);
    var totalPrimes = await Task.Run(()=>
        numbers
        .AsParallel()
        .Where(n => Enumerable.Range(2, (int)Math.Sqrt(n) - 1).All(i => n % i != 0))
        .Count());

    MessageBox.Show(totalPrimes.ToString());
}

或者让它更干净一点：

private async void btnMultiThread_Click(object sender, RoutedEventArgs e)
{
    var numbers = Enumerable.Range(2, range - 1);
    var totalPrimes = await Task.Run(()=>CalculatePrimes(numbers));
    MessageBox.Show(totalPrimes.ToString());
}

private int CalculatePrimes(IEnumerable<int> numbers)
{
    return numbers
          .AsParallel()
          .Where(n => Enumerable.Range(2, (int)Math.Sqrt(n) - 1).All(i => n % i != 0))
          .Count());
}

Answer 2

摘自微软关于Chaining Tasks by Using Continuation Tasks:

在异步编程中，一个异步是很常见的 操作完成后，调用第二个操作并传递数据 给它。传统上，这是通过使用回调方法完成的。在 任务并行库，提供相同的功能 继续任务。延续任务（也称为 continuation) 是由另一个任务调用的异步任务， 这被称为先行词，当先行词结束时。

这是一种方法：

private void btnMultiThread_Click(object sender, RoutedEventArgs e)
{
    Task<int>.Factory.StartNew(() =>
    {
        var numbers = Enumerable.Range(2, range - 1);
    var totalPrimes = numbers
            .AsParallel()
            .Where(n => Enumerable.Range(2, (int)Math.Sqrt(n) - 1).All(i => n % i != 0))
            .Count();
        return totalPrimes;
    }).ContinueWith(() => MessageBox.Show(antecendent.Result.ToString()); // Antecedent result feeds into continuation
}