非同期操作の頭を包み込む必要があります

Question

私はカスタムコントロールを持っていて、このコントロールがユーザーに公開するインターフェイスを持っています。

public interface ILookupDataProvider 
{ 
    string IdColumnName { get; } 

    IEnumerable<IDataColumn> Metadata { get; set; } 

    void GetDataAsync(string parameters, 
     Action<IEnumerable<object>> onSuccess, Action<Exception> onError); 
} 

だから、それはGetDataAsync

で非同期操作を公開する私の試みだが、私は、インターフェイスを実装して、私のクラスでこのメソッドを実装する方法がわかりません。私は実行するメソッドがあるので、この部分を理解してからonCompletion、onSucessまたはonError代理人が呼び出されます。

誰かがそれらを書く方法に関する構文を助けることができますか？

EDIT：

それは4.0だと私は

EDIT 2 awaitコマンドを使用することはできません：私は、データをロードするために效率フレームワークを使用しますが、このサンプルのため

- さんは、WCFをやらせます例えばサービス。インターフェイスの実装でWCFサービスコールをどのようにラップしますか？

また、このようなインターフェイスを作成して非同期操作を行うこともOKだと思いますか？あなたはイベントなどと違ってやりますか？

Answer 1

ここでの基本的な考え方は、クエリがバックグラウンドスレッドで発生するということです。操作が完了したら、新しい値を報告するためにonSuccessとonErrorコールバックを使用します。 、あなたが戻ってきているTaskを返すには

Task GetDataAsync(string parameters); 

：

void GetDataAsync(string parameters, 
    Action<IEnumerable<object>> onSuccess, Action<Exception> onError); 

は代わりに、これを使用する：例

void GetDataAsync(
    string parameters, 
    Action<IEnumerable<object>> onSuccess, 
    Action<Exception> onError) { 

    WaitCallback doWork = delegate { 
    try { 
     IEnumerable<object> enumerable = GetTheData(parameters); 
     onSuccess(enumerable); 
    } catch (Exception ex) { 
     onError(ex); 
    } 
    }; 

    ThreadPool.QueueUserWorkItem(doWork, null); 
} 

Answer 2

のためにあなたは本当にこのパターンを使用したくありません非同期作業単位を表すインスタンスそこから、APIの消費者はContinueWithに電話して、成功したときに何をするか、エラーがあるかどうかを決めることができます。

しかし、あなたの例には設計上の欠陥があります。 GetDataAsyncというメソッドでは、データが返されると思います。それは問題ではない、あなただけに署名を変更することができます。

Task<MyData> GetDataAsync(string parameters); 

この今あなたが（タスクが実行されていない場合、それはブロックされます）結果を得るためのResult propertyを使用することができますTask<T>を返しますか、非同期操作が完了したら、ContinueWithメソッドを再度使用してデータを処理できます。

また、あなたがあなたの操作をキャンセルする必要があるかどうかを決定するためのパラメータのCancellationToken structureインスタンスを実行できます。

Task<MyData> GetDataAsync(string parameters, 
    CancellationToken cancellationToken); 

ここでも、ContinueWithあなたがキャンセルに取るべきアクションを指示することができます。

これはとasyncを使用してAsync CTPのメソッドが現在どのようにモデル化されているのかを示しています。彼らはTaskまたはTask<T>を返す。あなたのコードで同じことをすると、これらの言語機能が焼き付けられたときに準備が整います。

Answer 3

タスクを使用するには、このように使用できます。覚えておかなければならない唯一のことは、TaskScheduler.FromCurrentSynchronizationContext（）で達成されるUIスレッドでコールバックを実行し、何か問題が生じた場合にUIを更新したり、メッセージボックスを表示できるようにすることです。

このようなイベント駆動型の性質のため、WCFを起動するボタンをハンマーで叩くと、要求を送信した順番に結果が戻ってこないことがあります。新しい操作を開始する場合や、タスクの実行中に後続の要求を無視する場合は、開始タスクを保存して最後に開始したタスクを取り消すことで、これを防ぐことができます。

private void button1_Click(object sender, EventArgs e) 
{ 
    GetDataAsync("www.data.com").ContinueWith(result => 
     { 
      if (result.Exception != null) 
      { 
       MessageBox.Show(this, "Error: {0}" + result.Exception, "Error"); 
      } 
      else 
      { 
       foreach (var obj in result.Result) 
       { 
        textBox1.Text += obj.ToString(); 
       } 
      } 
     }, 
     TaskScheduler.FromCurrentSynchronizationContext() 
     ); 

} 

Task<IEnumerable<object>> GetDataAsync(string parameters) 
{ 
    return Task<IEnumerable<object>>.Factory.StartNew(() => 
    { 
     Thread.Sleep(500); 
     // throw new ArgumentException("uups"); 
     // make wcf call here 
     return new object[] { "First", "second" }; 
    }); 
}