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に入ります。しかし、タスクは意図したとおりにそれぞれのプログレスバーを更新します。誰かが説明をすることができれば、それは高く評価されます。

Answer 1

これは古典的なトラップで、Task.Factory.StartNewです。このメソッドはTask<T>を返します。Tがコールバックの戻り値の型です。コールバックはReadFileで、タスクを返します。したがって、あなたはTask<Task>になり、内部タスクを待つ間に外部タスクを待っています。

2種類の溶液：

1. 推奨1：Task.Runの代わりTask.Factory.StartNewを使用しています。これは一般的な推奨事項です。適切な解決方法がわからない限り、Task.Factory.StartNewを使用しないでください。 Task.Runは、あなたが遭遇したような多くのトラップを回避します。

   var t1 = Task.Run(() => ReadFile(@"C:\BigFile1.txt", progressBar1)); 
   

2. あなたは、あなたが内側のいずれかに待つことができるようにタスクに.Unwrap()メソッドを使用することができ、Task.Factory.StartNewを使用する正当な理由がある場合：

   var t1 = Task.Factory.StartNew(() => ReadFile(@"C:\BigFile1.txt", progressBar1)).Unwrap();