顶级任务导致错误“当前 SynchronizationContext 可能无法用作 TaskScheduler。” [复制]

Question

虽然我查看了 stackoverflow 和文档，但我还没有看到答案。

如果我从计时器处理程序或另一个任务中调用创建任务的代码，则会在下面的 ContinueWidth 上出现此错误。例如，如果它被包装在另一个任务中，该任务每隔一段时间（例如每 1 秒）创建任务，如下所示。我拥有高级任务的唯一原因是每隔一段时间创建这些低级任务。

//更高级别的任务创建

...

Task task = Task.Factory.StartNew(new Action(UpdateAllDuringInterval));

...

    private void UpdateAllDuringInterval()
    {
        Stopwatch stopWatch = new Stopwatch();

        do
        {
            // Start the stopwatch
            stopWatch.Start();

            // Create tasks
            List<Task> tasks = CreateTasksAndStart();

            // Wait for the tasks to complete if testing, since want to check results
            if (this._testMode)
            {
                Task[] taskArray = tasks.ToArray();
                Task.WaitAll(taskArray);
            }

            if (!_testMode)
            {
                // Get remaining time to complete interval and sleep for that time
                int remainingTimeInMilliseconds = this._pollingIntervalInMilliseconds -
                                                  (int) stopWatch.Elapsed.TotalMilliseconds;
                    // truncating milliseconds
                if (remainingTimeInMilliseconds > 0)
                    Thread.Sleep(remainingTimeInMilliseconds);
                        // will give time to CPU. Note that using Sleep used to be frowned upon but no longer due to advantages in multitasksing/CPU utilization
            }
        } while (!_testMode); // continue updating stocks once per interval if not testing
    }

    private List<Task> CreateTasksAndStart()
    {
        var tasks = new List<Task>();

        lock (syncLock)
        {
            for (int i = 0; i < _stocksToUpdate.Count; i++)
            {
                var item = _stocksToUpdate[i];
                var initialTask = Task.Factory.StartNew(() =>
                {
                    GetUpdatedStockInformation(item);
                });
                var continuationTask = initialTask.ContinueWith((antecendent) =>
                {
                    UpdateUIWithUpdatedStockInformation();
                }
                , CancellationToken.None, TaskContinuationOptions.OnlyOnRanToCompletion,
                TaskScheduler.FromCurrentSynchronizationContext());

                // For testing, we want to wait on the continuation task to make sure updates are done
                tasks.Add(continuationTask);
            }
        }
        return tasks;
    }

如果需要更多信息，请告诉我。随意给我这个代码的其他陷阱。谢谢！

Answer 1

原因很简单，但解决方案可能需要您重新设计一些任务的交互。您没有设置SynchronizationContext（即SynchronizationContext.Current 为空），因此无法从中创建TaskScheduler。一种选择是在您在 UI 线程上运行的位置调用 TaskScheduler.FromCurrentSynchronizationContext()，然后向下传递到构造延续的方法。另一个是创建任务并传递它们，以便 UI 线程可以附加延续。

通常认为有像_testMode 这样的标志是一种代码异味，大概只测试代码集。然后你得到了一些你并没有真正测试的交互，因为测试代码做一件事，但实际的应用程序做另一件事。