public Task<bool> Submit(TaskScheduler ts, Func<bool> work, object state, TaskContinuationOptions taskContinuationOptions)
{
TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>(state, TaskCreationOptions.None);
Task t1 = new TaskFactory(_cts.Token, TaskCreationOptions.None, taskContinuationOptions, ts).StartNew(() =>
{
try
{
tcs.SetResult(work());
}
catch(Exception e)
{
tcs.SetException(e);
}
});
Task<bool> t2 = tcs.Task;
t2.ContinueWith(OnTaskSignaled);
return t2;
}
public void OnTaskSignaled(Task<bool> signaledTask)
{
BusinessItem item = (BusinessItem)signaledTask.AsyncState;
if (signaledTask.IsCanceled)
{
Console.WriteLine("{0} cancelled: Invalid State", item.Id);
}
else if (signaledTask.IsFaulted)
{
Console.WriteLine("{0} threw: {1}", item.Id, signaledTask.Exception);
}
else if (signaledTask.Result == true)
{
Console.WriteLine("{0} Succeeded", item.Id);
// continue to submit
}
else if (signaledTask.Result == false)
{
Console.WriteLine("{0} Incomplete, retry", item.Id);
Submit(_ts2, item.Work, item);
}
}
在上面的示例中,taskContinuationOptions 选项是否传播到 TaskCompletionSource.Task?在调试模式下,我可以看到 t1 和 t2 是两个不同的对象。实际上,如果将 state 传递给 StartNew(...),它只对 t1 可用,对 t2 不可用。
在这种情况下,TaskFactory 仅用于将工作提交给特定的 TaskScheduler,ts。它还创建另一个任务的事实使代码令人困惑。有没有更容易混淆的方法来做到这一点?我不明白为什么 TaskCompletionSource 作为任务生产者不像 TaskFactory 那样可配置。