.net 什么时候应该使用 TaskCompletionSource

发布于03月10日

AFAIK，它所知道的就是在某个时刻，它的SetResult或SetException方法被调用，以完成通过其Task属性公开的Task<T>.

换言之，它充当了a Task<TResult>及其完成的制作人.

我看到了here个例子:

如果我需要一种方法来异步执行一个Func<T>，并有一个Task<T>

public static Task<T> RunAsync<T>(Func<T> function) 
{ 
    if (function == null) throw new ArgumentNullException(“function”); 
    var tcs = new TaskCompletionSource<T>(); 
    ThreadPool.QueueUserWorkItem(_ => 
    { 
        try 
        {  
            T result = function(); 
            tcs.SetResult(result);  
        } 
        catch(Exception exc) { tcs.SetException(exc); } 
    }); 
    return tcs.Task; 
}

如果我没有Task.Factory.StartNew的话可以用-

Question:

有人能举例说明与directly到TaskCompletionSource有关的场景吗

推荐答案

我主要在只有基于事件的API可用时使用它(for example Windows Phone 8 sockets):

public Task<Args> SomeApiWrapper()
{
    TaskCompletionSource<Args> tcs = new TaskCompletionSource<Args>(); 

    var obj = new SomeApi();

    // will get raised, when the work is done
    obj.Done += (args) => 
    {
        // this will notify the caller 
        // of the SomeApiWrapper that 
        // the task just completed
        tcs.SetResult(args);
    }

    // start the work
    obj.Do();

    return tcs.Task;
}

因此，当与C#5 async关键字一起使用时，它尤其有用.