Promise tương đương trong C#

Question

Trong Scala có một lớp Promise có thể được sử dụng để hoàn thành một tương lai bằng tay. Tôi đang tìm kiếm một thay thế trong C#.

Tôi viết một bài kiểm tra và tôi muốn nó trông nó tương tự như sau:

// 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); 

Tôi hiểu rằng điều này có lẽ không phải là mô hình phù hợp với C#, nhưng tôi không thể tìm ra một cách hợp lý để đạt được điều tương tự ngay cả với mô hình hơi khác.

CHỈNH SỬA: xin lưu ý rằng async/await không giúp ích gì ở đây vì tôi không có Nhiệm vụ để chờ đợi! Tôi chỉ có quyền truy cập vào trình xử lý sẽ chạy trên một chuỗi khác.

Answer 1

Trong C#:

• Task<T> là một tương lai (hoặc Task cho một tương lai đơn vị trở lại).
• TaskCompletionSource<T> là lời hứa.

Vì vậy, mã của bạn sẽ dịch như vậy:

// 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); 

Các "theo thời gian chờ đợi không đồng bộ" là một chút vụng về, nhưng nó cũng tương đối phổ biến trong mã thực tế. Đối với các bài kiểm tra đơn vị, tôi sẽ chỉ thực hiện chờ đợi không đồng bộ thông thường:

var promise = new TaskCompletionSource<MyResult>(); 

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

var myResult = await promise.Task; 

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

Answer 2

Thử tìm kiếm mô hình không đồng bộ. Nhiệm vụ là tương đương gần nhất trong C#.

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

Answer 3

Bạn có thể sử dụng C# Promises thư viện

mở nguồn trên Github: https://github.com/Real-Serious-Games/C-Sharp-Promise

Khả dụng trên NuGet: https://www.nuget.org/packages/RSG.Promise/

Answer 4

Các thô C# tương đương mà không thư viện của bên thứ ba sẽ là:

// 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); 
} 

Lưu ý rằng tốt nhất nên sử dụng các mức await/async đến mức cao nhất có thể. Truy cập vào Result trong số Task hoặc sử dụng Wait có thể trong một số trường hợp introduce deadlocks.