如何強制任務等待子任務？

Question

我必須使用一個API來強制實現其回調接口的類作爲身份驗證方法的參數。

public class CallBack : ICallBack 
{ 
    public object Response; 
    public void OnSuccess(object response) 
    { 
     Response = response; 
    } 
    public void OnException(Exception ex) { } 
} 

驗證呼叫

public async Task<bool> LoginAsync(string username, string password) 
{ 
    CallBack callback = new CallBack(); 
    await Task.Factory.StartNew(
     () => userService.Authenticate(username, password, callback), 
      TaskCreationOptions.AttachedToParent); 
    return callback.Response is User ? true : false; 
} 

的問題是，在回調之前LoginAsync完成被調用。我希望通過使用TaskCreationOptions.AttachedToParent啓動Authenticate呼叫，它會傳播到在Authenticate開始的任何子任務，但它不會。

Answer 1

您應該使用TaskCompletionSource對象將基於回調的異步方法包裝爲等待任務。

我假設你ICallBack是這樣的：

public interface ICallBack 
{ 
    void OnSuccess(object response); 
    void OnException(Exception ex); 
} 

所以，你可以這樣實現LoginAsync：

public async Task<bool> LoginAsync(string username, string password) 
{ 
    var tcs = new TaskCompletionSource<object>(); 
    ICallBack callback = new CallBackAsync(tcs); 
    userService.Authenticate(username, password, callback); 
    var result = await tcs.Task; 
    return result is User ? true : false; 
} 

public class CallBackAsync : ICallBack 
{ 
    private TaskCompletionSource<object> _tcs; 
    public CallBackAsync(TaskCompletionSource<object> tcs) 
    { 
     _tcs = tcs; 
    } 

    public void OnSuccess(object response) 
    { 
     _tcs.TrySetResult(response); 
    } 
    public void OnException(Exception ex) { 
     _tcs.TrySetException(ex); 
    } 
} 

對於簡單解釋，當您使用Task.Factory.StartNew（）在lambda表達式的末尾提出完成任務。但在你的情況下，這發生在CallBack.OnSuccess調用之前。所以結果沒有設置。

TaskCompletionSource類允許您完全控制何時必須完成任務完成。