Khi nào sử dụng TaskEx.Run và TaskEx.RunEx

Question

Tôi đang cố gắng hiểu khi nào nên sử dụng TaskEx.Run. Tôi đã cung cấp hai mẫu mã tôi đã viết dưới đây mà sản xuất cùng một kết quả. Những gì tôi không thấy là lý do tại sao tôi sẽ lấy Task.RunExTaskEx.RunEx cách tiếp cận , tôi chắc chắn có một lý do chính đáng và đã hy vọng ai đó có thể điền vào tôi trong.

async Task DoWork(CancellationToken cancelToken, IProgress<string> progress) 
{ 
    int i = 0; 
    TaskEx.RunEx(async() => 
     { 
      while (!cancelToken.IsCancellationRequested) 
      { 
       progress.Report(i++.ToString()); 
       await TaskEx.Delay(1, cancelToken); 
      } 
     }, cancelToken); 
} 
private void Button_Click(object sender, RoutedEventArgs e) 
{ 
    if (button.Content.ToString() == "Start") 
    { 
     button.Content = "Stop"; 
     cts.Dispose(); 
     cts = new CancellationTokenSource(); 
     listBox.Items.Clear(); 
     IProgress<string> progress = new Progress<string>(s => 
     { 
      listBox.Items.Add(s); 
      listBox.ScrollIntoView(listBox.Items[listBox.Items.Count - 1]); 
     }); 
     DoWork(cts.Token, progress); 
    } 
    else 
    { 
     button.Content = "Start"; 
     cts.Cancel(); 
    } 
} 

tôi có thể đạt được kết quả tương tự giống như vậy

async Task DoWork(CancellationToken cancelToken) 
    { 
     int i = 0; 
     while (!cancelToken.IsCancellationRequested) 
     { 
      listBox.Items.Add(i++); 
      listBox.ScrollIntoView(listBox.Items[listBox.Items.Count - 1]); 
      await TaskEx.Delay(100, cancelToken); 

     } 
    } 

    private void Button_Click(object sender, RoutedEventArgs e) 
    { 
     if (button.Content.ToString() == "Start") 
     { 
      button.Content = "Stop"; 
      cts.Dispose(); 
      cts = new CancellationTokenSource(); 
      listBox.Items.Clear(); 
      DoWork(cts.Token); 
     } 
     else 
     { 
      button.Content = "Start"; 
      cts.Cancel(); 
     } 
    } 

Answer 1

Task.Run sinh ra một chuỗi mới trong hầu hết các trường hợp như tôi đã hiểu. Điều quan trọng cần lưu ý là đơn giản vì bạn đánh dấu một phương thức là không đồng bộ, và sử dụng awaiters, điều này KHÔNG (nhất thiết) có nghĩa là các luồng mới đang được tạo, các lần hoàn thành được lên lịch trên chuỗi thực thi SAME mà chúng được gọi từ trong nhiều trường hợp.

Bí quyết ở đây phải làm với SchedulingContext. Nếu nó được thiết lập cho một căn hộ đa luồng, sau đó bạn sẽ đại biểu hoàn thành các chủ đề khả thi trên threadpool. Nếu bạn đang ở trong một căn hộ đơn giản như tất cả các mã WPF và WinForms UI, thì nó sẽ trở về chuỗi gọi để hoàn thành cho phép công việc được thực hiện trực tiếp trên giao diện người dùng mà không nhìn thấy chủ đề marshalling trong mã.

Answer 2

Sử dụng TaskEx.Run khi bạn muốn chạy mã đồng bộ trong ngữ cảnh nhóm luồng.

Sử dụng TaskEx.RunEx khi bạn muốn chạy mã không đồng bộ trong ngữ cảnh nhóm luồng.

Stephen Toub có hai bài đăng trên blog liên quan đến sự khác biệt trong hành vi:

• Potential pitfalls to avoid when passing around async lambdas
• Task.Run vs Task.Factory.StartNew

Đây chỉ là một trong nhiều lựa chọn bạn có cho creating tasks. Nếu bạn không phải sử dụng Run/RunEx, thì bạn không nên sử dụng. Sử dụng các phương thức async đơn giản và chỉ sử dụng Run/RunEx nếu bạn cần chạy một thứ gì đó ở chế độ nền.

Answer 3

Sự khác biệt giữa hai phương pháp DoWork() của bạn là phương pháp đầu tiên (sử dụng TaskEx.RunEx()) hoàn toàn không đồng bộ. Nó thực thi hoàn toàn đồng bộ, khởi động tác vụ khác trên một luồng khác, và ngay lập tức trả về Task hoàn thành. Nếu bạn await ed hoặc Wait() chỉnh sửa tác vụ đó, nó sẽ không đợi cho đến khi hoàn thành nhiệm vụ nội bộ.