如何使用 TaskScheduler 安排 TaskCompletionSource.Task？

Question

    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 那样可配置。

Answer 1

您没有理由使用TaskCompletionSource。如果您从 lambda 返回值，则从 StartNew() 返回的 Task 将包含您想要的内容：成功时的结果和失败时的异常。

另外，我认为TaskFactory 中的TaskContinuationOptions 仅适用于直接通过工厂启动的延续（例如使用ContinueWhenAll()）。因此，我认为您根本不需要TaskFactory，但您应该分别为每个任务（原始任务和延续任务）指定选项。虽然我认为当前方法之外的人应该设置内部延续的执行方式很奇怪。

回答您的问题：安排TaskCompletionSource 和一些TaskFactory 是没有意义的，因为TaskCompletionSource 实际上并没有执行。

通过这些更改，您的代码将如下所示：

public Task<bool> Submit(
    TaskScheduler ts, Func<bool> work, object state,
    TaskContinuationOptions taskContinuationOptions)
{
    var task = Task.Factory.StartNew(_ => work(), state, _cts.Token);

    task.ContinueWith(OnTaskSignaled, _cts.Token, taskContinuationOptions,
                      TaskScheduler.Default);

    return task;
}