ждут какого-либо метод асинхронных и (событие или логический)

Question

У меня есть этот код:

ManualResetEvent EventListenerStopped; 
... 
while (true) 
{ 
    IAsyncResult iar = this.ListenerHttp.BeginGetContext(ProcessRequest, null); 
    if (WaitHandle.WaitAny(new[] { this.EventListenerStopped, iar.AsyncWaitHandle }) == 0) 
     return; 
} 

В основном он ждет любого из двух событий:

• если запрос получен, он обрабатывает его и дождитесь следующего.
• если EventListenerStopped поднят, он выходит из цикла.

Этот код работает в производстве красиво уже довольно давно.

Я хотел попробовать и преобразовать его в новый механизм ожидания/асинхронности и, похоже, не может найти хороший простой способ сделать это.

Я попробовал с булевым, вызывающий может обратиться к false. Это, очевидно, не работает, как он выходит из цикла только после того, как новый запрос был получен и обработан:

bool RunLoop; 
... 
while (this.RunLoop) 
{ 
    HttpListenerContext listenerContext = await this.ListenerHttp.GetContextAsync(); 
    ProcessRequest(listenerContext); 
} 

Я интересно, если это возможно даже переписать мой простой цикл в старом стиле с асинхронным/ждут. Если да, хотел бы кто-нибудь показать мне, как это сделать?

Answer 1

Это не относится к асинхронным-ОЖИДАНИЕ, но вы, вероятно, ищет CancellationToken (который используется с большим количеством асинхронным-ждать кода в любом случае):

http://blogs.msdn.com/b/pfxteam/archive/2009/05/22/9635790.aspx

«BlockingOperation» Пример кода кажется, похоже на то, что вы пытаетесь сделать:

void BlockingOperation(CancellationToken token) 
{ 
    ManualResetEvent mre = new ManualResetEvent(false); 
    //register a callback that will set the MRE 
    CancellationTokenRegistration registration = 
     token.Register(() => mre.Set()); 
    using (registration) 
    { 
     mre.WaitOne(); 
     if (token.IsCancellationRequested) //did cancellation wake us? 
      throw new OperationCanceledException(token); 
    } //dispose the registration, which performs the deregisteration. 
} 

Answer 2

Ну, во-первых, я должен отметить, что старый код не д uite правильно. Когда вы работаете с Begin/End pattern, вы должны всегда звонить End, даже если вы хотите (или сделали) отменить операцию. End часто используется для утилизации ресурсов.

Если вы хотите использовать аннулирование, CancellationToken, вероятно, лучший подход:

while (true) 
{ 
    // Throws an OperationCanceledException when cancellationToken is canceled. 
    var request = await this.ListenerHttp.GetContextAsync(cancellationToken); 
    ProcessRequest(request); 
} 

Есть альтернативы - это возможного сделать что-то вроде Task.WhenAny, и есть даже реализации AsyncManualResetEvent, так можно создать почти по очереди эквивалент старого кода, но ИМО подход маркера отмены будет более чистым.

Например, с помощью AsyncManualResetEvent from my AsyncEx library:

AsyncManualResetEvent eventListenerStopped; 
while (true) 
{ 
    var task = GetContextAndProcessRequestAsync(); 
    if (await Task.WhenAny(eventListenerStopped.WaitAsync(), task) != task) 
    return; 
} 

async Task GetContextAndProcessRequestAsync() 
{ 
    var request = await this.ListenerHttp.GetContextAsync(); 
    ProcessRequest(request); 
} 

Но лично я изменил бы использовать CancellationToken.