Обещающий эквивалент в C#

Question

В Scala есть класс Promise, который можно использовать для завершения Будущего вручную. Я ищу альтернативу в C#.

Я пишу тест, и я хочу, чтобы это выглядело это примерно так:

// var MyResult has a field `Header` 
var promise = new Promise<MyResult>; 

handlerMyEventsWithHandler(msg => 
    promise.Complete(msg); 
); 

// Wait for 2 seconds 
var myResult = promise.Future.Await(2000); 

Assert.Equals("my header", myResult.Header); 

Я понимаю, что это, вероятно, не правильный шаблон для C#, но я не мог понять, разумный способ для достижения той же самой вещи даже с несколько иной структурой.

EDIT: обратите внимание, что async/await здесь не помогает, так как у меня нет задаче ждать! Я просто имею доступ к обработчику, который будет запущен в другом потоке.

Answer 1

В C#:

• Task<T> это будущее (или Task для будущего блока, возвращающих).
• TaskCompletionSource<T> является обещанием.

Так что ваш код будет перевести так:

// var promise = new Promise<MyResult>; 
var promise = new TaskCompletionSource<MyResult>(); 

// handlerMyEventsWithHandler(msg => promise.Complete(msg);); 
handlerMyEventsWithHandler(msg => promise.TrySetResult(msg)); 

// var myResult = promise.Future.Await(2000); 
var completed = await Task.WhenAny(promise.Task, Task.Delay(2000)); 
if (completed == promise.Task) 
    ; // Do something on timeout 
var myResult = await completed; 

Assert.Equals("my header", myResult.Header); 

«приуроченная асинхронным ожидание» немного неудобно, но это также сравнительно редко в реальном коде. Для модульных тестов, я бы просто сделать регулярное асинхронное ожидание:

var promise = new TaskCompletionSource<MyResult>(); 

handlerMyEventsWithHandler(msg => promise.TrySetResult(msg)); 

var myResult = await promise.Task; 

Assert.Equals("my header", myResult.Header); 

Answer 2

Попробуйте взглянуть на асинхронную модель. Задачи - ближайший эквивалент в C#.

Here's a link to an MS Article explaining their use.

Answer 3

Вы можете использовать C# Обещания библиотеку

с открытым исходным кодом на Github: https://github.com/Real-Serious-Games/C-Sharp-Promise

Доступно NuGet: https://www.nuget.org/packages/RSG.Promise/

Answer 4

Грубая C# эквивалент без сторонних библиотек будет:

// var MyResult has a field `Header` 
var promise = new TaskCompletionSource<MyResult>(); 

handlerMyEventsWithHandler(msg => 
    promise.SetResult(msg) 
); 

// Wait for 2 seconds 
if (promise.Task.Wait(2000)) 
{ 
    var myResult = promise.Task.Result; 
    Debug.Assert("my header" == myResult.Header); 
} 

Обратите внимание, что лучше всего использовать await/async как можно более высоким уровнем. Доступ к Result из Task или с использованием Wait может в некоторых случаях introduce deadlocks.