C# gọi lại async vẫn còn trên nền chủ đề ... giúp đỡ! (tốt nhất là không có InvokeRequired)

Question

Tôi đang viết một lớp trợ giúp không đồng bộ rất đơn giản để đi cùng với dự án của tôi. Mục đích của lớp là nó cho phép một phương thức được chạy trên một luồng nền. Đây là mã;

    internal class AsyncHelper 
    { 
     private readonly Stopwatch timer = new Stopwatch(); 
     internal event DownloadCompleteHandler OnOperationComplete; 

     internal void Start(Func func, T arg) 
     { 
      timer.Start(); 
      func.BeginInvoke(Done, func); 
     } 

     private void Done(IAsyncResult cookie) 
     { 
      timer.Stop(); 
      var target = (Func) cookie.AsyncState; 
      InvokeCompleteEventArgs(target.EndInvoke(cookie)); 
     } 

     private void InvokeCompleteEventArgs(T result) 
     { 
      var args = new EventArgs(result, null, AsyncMethod.GetEventByClass, timer.Elapsed); 
      if (OnOperationComplete != null) OnOperationComplete(null, args); 
     } 

     #region Nested type: DownloadCompleteHandler 

     internal delegate void DownloadCompleteHandler(object sender, EventArgs e); 

     #endregion 
    } 

Kết quả của tác vụ sau đó được trả về thông qua sự kiện OnOperationComplete. Vấn đề là khi sự kiện được nâng lên, nó vẫn còn trên chủ đề nền. I E. nếu tôi cố gắng để chạy mã này (dưới đây) tôi nhận được một lỗi luồng chéo;

txtOutput.AppendText(e.Result + Environment.NewLine);

Vui lòng thông báo cho mọi suy nghĩ.

Answer 1

Sử dụng lớp BackgroundWorker. Về cơ bản nó giống như bạn muốn.

 private BackgroundWorker _worker; 

    public Form1() 
    { 
     InitializeComponent(); 
     _worker = new BackgroundWorker(); 
     _worker.DoWork += Worker_DoWork; 
     _worker.RunWorkerCompleted += Work_Completed; 
    } 

    private void Work_Completed(object sender, RunWorkerCompletedEventArgs e) 
    { 
     txtOutput.Text = e.Result.ToString(); 
    } 

    private void Worker_DoWork(object sender, DoWorkEventArgs e) 
    { 
     e.Result = "Text received from long runing operation"; 
    } 

Answer 2

Bạn cần phải gọi sự kiện của bạn trên thread UI,

WinForms

Form1.BeginInvoke(...);

WPF

Dispatcher.BeginInvoke(...);

Answer 3

Sử dụng lớp BackgroundWorker, bạn về cơ bản reimplementing nó đây.

Answer 4

Trừ khi bạn xây dựng lớp giúp đỡ của bạn để làm bối cảnh chuyển trong nội bộ bạn sẽ luôn luôn cần phải gọi trong xử lý sự kiện bởi vì trong mã của bạn ở trên, bạn đang làm dấy lên sự kiện trên thread phi ui.

Để làm điều đó, người trợ giúp của bạn cần phải biết cách lấy lại chuỗi ui. Bạn có thể chuyển số ISynchronizeInvoke cho người trợ giúp và sau đó sử dụng nó khi hoàn tất. Somwthing như:

ISynchronizeInvoke _sync; 
internal void Start(Func func, T arg, ISynchronizeInvoke sync) 
{ 
    timer.Start(); 
    func.BeginInvoke(Done, func); 
    _sync = sync; 
} 

private void InvokeCompleteEventArgs(T result) 
{ 
    var args = new EventArgs(result, null, AsyncMethod.GetEventByClass, timer.Elapsed); 
    if (OnOperationComplete != null) 
    _sync.Invoke(OnOperationComplete, new object[]{null, args}); 
} 

Lớp Control thực hiện ISynchronizeInvoke để bạn có thể vượt qua con trỏ this từ Form hoặc Control mà các cuộc gọi helper và có các đại biểu xử lý sự kiện,

Answer 5

tôi khuyên bạn nên sử dụng các lớp chứ không phải TaskBackgroundWorker, nhưng either would be greatly superior to Control.Invoke or Dispatcher.Invoke.

Ví dụ:

internal class AsyncHelper<T> 
{ 
    private readonly Stopwatch timer = new Stopwatch(); 
    private readonly TaskScheduler ui; 

    // This should be called from a UI thread. 
    internal AsyncHelper() 
    { 
    this.ui = TaskScheduler.FromCurrentSynchronizationContext(); 
    } 

    internal event DownloadCompleteHandler OnOperationComplete; 

    internal Task Start(Func<T> func) 
    { 
    timer.Start(); 
    Task.Factory.StartNew(func).ContinueWith(this.Done, this.ui); 
    } 

    private void Done(Task<T> task) 
    { 
    timer.Stop(); 
    if (task.Exception != null) 
    { 
     // handle error condition 
    } 
    else 
    { 
     InvokeCompleteEventArgs(task.Result); 
    } 
    } 

    private void InvokeCompleteEventArgs(T result) 
    { 
    var args = new EventArgs(result, null, AsyncMethod.GetEventByClass, timer.Elapsed); 
    if (OnOperationComplete != null) OnOperationComplete(null, args); 
    } 

    internal delegate void DownloadCompleteHandler(object sender, EventArgs e); 
} 

Điều này rất giống với BackgroundWorker, mặc dù (ngoại trừ bạn đang thêm bộ hẹn giờ). Bạn có thể muốn xem xét chỉ sử dụng BackgroundWorker.