既存の非同期APIでTPLを使用する

Question

既存のAPI RestSharpを使用してTPLを使用したいので、継続を使用できます。

しかし、これは、古典的な.NETのアプローチを非同期に取らず、代わりにコールバックを実装するAPIをラップする必要があることを意味します。

var client = new RestClient("service-url"); 
var request = new RestRequest(); 

client.ExecuteAsync<List<LiveTileWeatherResponse>>(request, 
    (response) => 
    { 
     ... 
    }); 

ここで、可能であれば、ExecuteAsyncをTPLにラップしたいと思います。しかし私は私の人生のために、それをする方法を理解することはできません。

アイデア？

Answer 1

TPLは、タスクとしてほとんどすべてを公開できるようにするTaskCompletionSourceクラスを提供します。 SetResultまたはSetExceptionを呼び出すと、タスクの成功または失敗を引き起こすことができます。あなたの例では、おそらくのようなもの行うことができます：

static Task<T> ExecuteTask<T>(this RestClient client, RestRequest request) 
{ 
    var tcs = new TaskCompletionSource<T>(); 
    client.ExecuteAsync<T>(request, response => tcs.SetResult(response)); 
    return tcs.Task; 
} 

をあなたはそれを使用することができます。

var task = client.ExecuteTask<List<LiveTileWeatherResponse>>(request); 
foreach (var tile in task.Result) 
{} 

それとも、あなたがチェーンのタスクにしたい場合：

var task = client.ExecuteTask<List<LiveTileWeatherResponse>>(request); 
task.ContinueWith(
    t => 
    { 
     foreach (var tile in t.Result) 
     {} 
    } 
); 

あなたが読むことができますTaskCompletionSourceの詳細については、http://blogs.msdn.com/b/pfxteam/archive/2009/06/02/9685804.aspx

Answer 2

これは私にとって大きな苦労点でした。 g TPLも同様です。

あなたが探しているのはTaskCompletionSourceです。 TaskCompletionSourceを作成すると、対応するTaskCompletionSourceのSetResultまたはSetExceptionメソッドを呼び出すと完了する特殊なTaskオブジェクト（TaskCompletionSource.Taskプロパティでアクセス可能）が作成されます。

この投稿はhow to wrap APM operations with the TPL（およびRxも）について説明しています。 this gistも参照してください。これは、TPLでラップされたAPM操作を示しています。