Эффективное ограничение скорости асинхронных задач (N выполнений за промежуток времени)

Question

Как реализовать эффективный алгоритм ограничения скорости (N выполнения определенного действия за промежуток времени) при использовании .Net 4.0/4.5 Задачи? Например, я хочу, чтобы SendMessageAsync блокировал (не отправляя другое сообщение), если больше N сообщений, отправленных за секунду.

 await Task.WhenAll(
        Enumerable.Range(0, TOTAL_MESSAGES) 
        .Select(async x => 
        { 
         await clientSession.SendMessageAsync(CreateMessage()); 
        })); 

Я попытался с помощью Task.Delay внутри SendMessageAsync, но так как в ожидании Task.Delay мгновенную возвращается, то следующее сообщение будет отправлено без блокировки.

public async Task<ResponseMessage> SendMessageAsync(RequestMessage message) 
{ 

    int sleepTime; 
    if (throttler.ShouldThrottle(out sleepTime)) 
    { 
     await Task.Delay(sleepTime); 
    } 

    return await InternalMessageWithoutWaitingAsync(message); 
} 

Я мог бы изменить await Task.Delay(sleepTime) в Thread.Sleep(sleepTime) таким образом ждет, прежде чем асинхронная, но мне интересно, если это хорошая практика, при использовании задач.

Answer 1

Использование Thread.Sleep не является хорошей практикой в ​​коде async.

Вы могли бы получить то, что вам нужно, как это:

private SemaphoreSlim _semaphore = new SemaphoreSlim(N); 
public async Task<ResponseMessage> SendMessageAsync(RequestMessage message) 
{ 
    await _semaphore.WaitAsync(); 
    try 
    { 
    return await InternalMessageWithoutWaitingAsync(message); 
    } 
    finally 
    { 
    ReleaseSemaphoreAfterDelayAsync(); 
    } 
} 

private async Task ReleaseSemaphoreAfterDelayAsync() 
{ 
    await Task.Delay(TimeInterval); 
    _semaphore.Release(); 
}