Có cách nào chung để đồng bộ hóa một phương pháp không đồng bộ không?

Question

Chúng tôi có kịch bản phổ biến này, nơi chúng tôi có một phương pháp thực hiện một số hành động asyncronously và đặt ra một sự kiện khi nó được thực hiện.

Có những lúc mà chúng tôi muốn nó được thực hiện đồng bộ thay vì vậy chúng tôi có mã trông tương tự như sau:

ManualResetEvent reset = new ManualResetEvent(false); 
someobject.AsyncActionDone += (sender, args) => reset.Set(); 
someobject.PerformAsyncAction(); 
reset.WaitOne(); 

Có cách nào để viết một phương pháp helper để làm điều này? Tôi có thể vượt qua trong Action để thực hiện, nhưng tôi không chắc chắn làm thế nào để vượt qua một cái gì đó cho phép phương thức trợ giúp biết sự kiện nào để nghe vì nó không giống như bạn có thể truyền vào một EventHandler như một tham số.

Tốt một giải pháp mà không đòi hỏi phản ánh

Dường như có một số nhầm lẫn, đây là một mẫu của những gì SomeObject của lớp cũng giống như:

public class SomeClass 
{ 
    private ExternalServer someServerOverTheNetwork = new ExternalServer(); 

    public event EventHandler AsyncActionDone; 
    public Data SomeData { get; set; } 
    public void PerformAsyncAction() 
    { 
     someServerOverTheNetwork.GetSomeData(OnDataRetrived); 
    } 

    public Data OnDataRetrived(Data someData) 
    { 
     AsyncActionDone(this, new DataEventArgs(someData)); 
    } 
} 

Answer 1

Tôi sẽ xem xét triển khai Asynchronous Design Pattern trong các đối tượng thực hiện thao tác không đồng bộ.

public object Operation(object arg) 
{ 
    var ar = BeginOperation(arg, null, null); 

    return EndOperation(ar); 
} 

public IAsyncResult BeginOperation(object arg, AsyncCallback asyncCallback, object state) 
{ 
    AsyncResult asyncResult = new AsyncResult(asyncCallback, state); 

    // Lauch the asynchronous operation 

    return asyncResult; 
} 

private void LaunchOperation(AsyncResult asyncResult) 
{ 
    // Do something asynchronously and call OnOperationFinished when finished 
} 

private void OnOperationFinished(AsyncResult asyncResult, object result) 
{ 
    asyncResult.Complete(result); 
} 


public object EndOperation(IAsyncResult asyncResult) 
{ 
    AsyncResult ar = (AsyncResult)asyncResult; 

    return ar.EndInvoke(); 
} 

Với mẫu này, bạn có thể linh hoạt đồng thời nhiều thao tác không đồng bộ trên đối tượng của mình.

Lưu ý: Bạn có thể dễ dàng tìm thấy triển khai lớp AsyncResult chung trên web.

Edit:

Như bạn muốn giữ lại các thiết kế hiện nay, nếu tất cả các đối tượng của bạn chỉ có thể có một hoạt động không đồng bộ, sau đó bạn có thể định nghĩa một giao diện IAsyncOperation và thực hiện nó trong tất cả các đối tượng của bạn.

public interface IAsyncOperation 
{ 
    event EventHandler AsyncActionDone; 
    void PerformAsyncAction(); 
} 

Sau đó, bạn có thể có:

public static CallSynchronously(IAsyncOperation asyncOperation) 
{ 
    ManualResetEvent reset = new ManualResetEvent(false); 
    asyncOperation.AsyncActionDone += (sender, args) => reset.Set(); 
    asyncOperation.PerformAsyncAction(); 
    reset.WaitOne(); 
} 

Nếu đối tượng của bạn có thể chứa nhiều hoạt động không đồng bộ, sau đó mà không suy nghĩ Tôi nghĩ rằng không có cách nào để đạt được những gì bạn muốn làm, nhưng bạn vẫn có thể xác định một phiên bản đồng bộ của tất cả các hoạt động không đồng bộ kết thúc tốt đẹp ManualResetEvent.

public void PerformAction() 
{ 
    ManualResetEvent reset = new ManualResetEvent(false); 
    this.AsyncActionDone += (sender, args) => reset.Set(); 
    this.PerformAsyncAction(); 
    reset.WaitOne(); 
} 

Answer 2

Nếu tôi bắt trôi dạt của bạn, bạn có thể chỉ cần sử dụng các đại biểu theo cách sau, tạo ra một đại biểu cho bạn chức năng cuộc gọi, cho phép gọi nó là

public delegate string AsyncDelegate(); 

sau đó, tạo một funct Proxy ion như thế này:

public static void ExecuteSync(AsyncDelegate func) 
    { 
     ManualResetEvent reset = new ManualResetEvent(false); 
     int threadId; 
     func.BeginInvoke((a)=>reset.Set(), null); 
     reset.WaitOne(); 
    } 

Thats tất cả, bạn có thể làm cho nó phức tạp hơn một chút bằng cách thêm một chức năng đại biểu để chạy sau khi hoàn thành hoặc một cái gì đó như thế ..

Thưởng thức!