TPL и монитор в PCL

Question

Итак, я пишу библиотеку клиентских API PCL (.NET 4.5, SL 5, Win8, WP8.1, WP SL 8), и я решил, что я только позволю себе HTTP-запрос за раз. В настоящее время я использую TPL, чтобы сделать их:

Task.Factory.FromAsync<Stream>(httpReq.BeginGetRequestStream, httpReq.EndGetRequestStream, null).ContinueWith<Task<WebResponse>>((requestStreamTask) => 
{ 
    return Task<WebResponse>.Factory.FromAsync(httpReq.BeginGetResponse, httpReq.EndGetResponse, null); 
}).Unwrap().ContinueWith<HttpWebResponse>((getResponseTask) => 
    { 
     return (HttpWebResponse)getResponseTask.Result; 
    }); 

Так что я хочу, чтобы добавить блокировку, чтобы предотвратить более одного запроса от перехода на один раз. Я знаю, что могу просто позвонить Monitor.Enter, прежде чем начать, и позвонил Monitor.Exit в последних ContinueWith. Но на основе Migrating lock to TPL я не могу использовать Monitor, так как это возможно из-за проблем с потоками. У меня нет проблем с использованием другого объекта блокировки, такого как рекомендация, но, насколько я могу судить в моем PCL, единственной блокировкой, которую я имею в наличии, является Monitor.

Итак, что мне делать?

EDIT: После разговора с Юваль Itzchakov ниже я понял причину я только иметь Monitor класс для синхронизации, потому что у меня есть поддержка Silverlight 5 в моем PCL. Если нет другого способа, я рассмотрю отказ от поддержки SL5, но я бы предпочел.

EDIT2: После беспорядка я понял, что у меня есть класс ManualResetEvent, могу ли я использовать его?

Answer 1

Поскольку вы пишете PCL и включаете некоторые старые платформы (в частности, SL5), ваши варианты немного ограничены. TPL Dataflow не поддерживается на SL5, и ни один из них не является SemaphoreSlim.

Однако HttpClient is и so are async/await. Они позволяют вашему коду быть далеко, намного чище, чем Task.Factory.FromAsync + Unwrap + ContinueWith.

Для портативных async-уже синхронизации и/или производителей/очередей потребителей я рекомендую свои собственные AsyncEx library. В этом случае должно быть достаточно AsyncLock; он может быть использован аналогичным образом SemaphoreSlim:

private readonly HttpClient _client = new HttpClient(); 
private readonly AsyncLock _mutex = new AsyncLock(); 

public async Task<string> GetStringAsync(string url) 
{ 
    using (await _mutex.LockAsync()) 
    { 
     return await _client.GetStringAsync(url); 
    } 
} 

Answer 2

Прежде всего, в этом ответе я использовал SemaphoreSlim, который указан в documentation, он поддерживается в PCL, поэтому вы можете использовать его вместо Monitor.

Во-вторых, в качестве Jon Skeet pointed out вы можете использовать TPL Dataflow-х ActionBlock (также поддерживается в PCL (с async-await:

var block = new ActionBlock<HttpWebRequest>(request => 
{ 
    var result = await request.GetResponseAsync(); 
    // handle result 
} 

HttpWebRequest newRequest = // ... 
block.Post(newRequest); 

Блок обрабатывает все запросы, по одному за раз, и вы добавляете новые унции с помощью Post

Answer 3

.

Вместо того, используя довольно подробный FromAsync шаблон, вы можете использовать HttpClient и SemaphoreSlim (как Арнон и Джон упоминается), которые поддерживают PCL:

private SemaphoreSlim _semaphoreSlim = new SemaphoreSlim(1, 1); 

private HttpClient _httpClient = new HttpClient(); 

public async Task SendRequestAsync(HttpWebRequest request) 
{ 
     await _semaphoreSlim.WaitAsync(); 
     try 
     { 
     return await _httpClient.SendAsync(request); 
     } 
     finally 
     { 
     _semaphoreSlim.Release(); 
     } 
}