TaskScheduler.FromCurrentSynchronizationContext исключение при вызове из рабочего потока

Question

Не совсем уверен, что здесь происходит -

Этот бит кода вызывает проблемы, так как он первый из основной нити (проверено с точки зрения задач в VS) и планирование задачи, однако при установке точки останова в UpdateSearchCache мы сейчас в рабочем потоке - больше не основной!

Последующие фрагменты кода пользовательского интерфейса, вызываемые оттуда, не могут выполняться в рабочем потоке.

Разве это не все, что нужно для определения планировщика? Что мне не хватает?

Этот код вызывается при запуске нашего приложения. Он вызывается из Bootstrapper нашего приложения PRISM и работает на MainThread.

SynchronizationContext.Current не имеет значения, когда задача запущена.

var currentScheduler = TaskScheduler.FromCurrentSynchronizationContext(); 
var ctx = SynchronizationContext.Current; 
if (ctx == null) 
    throw new NullReferenceException(); 

Task.Factory 
    .StartNew(
     () => 
      SearchHelper.CacheSearchResults(_service.GetData()) 
    .ContinueWith(result => UpdateCache(result.Result), currentScheduler); 

Answer 1

TaskScheduler.FromCurrentSynchronizationContext бросает InvalidOperationException, когда нет никакого контекста синхронизации на вызывающий поток т.е. SynchronizationContext.Current возвращает нуль.

Answer 2

Что-то действительно странное происходит здесь. Попробуйте следующий подход. Это обходное решение, но оно также может помочь в диагностике проблемы:

var dispatcher = Dispatcher.CurrentDispatcher; 
Debug.Assert(dispatcher == Application.Current.Dispatcher); 

Task.Factory 
    .StartNew(
     () => SearchHelper.CacheSearchResults(_service.GetData())) 
    .ContinueWith(result => 
    { 
     // is the app's dispatcher still the same? 

     Debug.Assert(dispatcher == Application.Current.Dispatcher); 

     // explicitly use Dispatcher.BeginInvoke, that's what 
     // DispatcherSynchronizationContext does behind the scene 

     Application.Current.Dispatcher.BeginInvoke(new Action(
      () => UpdateCache(result.Result))); 

    }, TaskContinuationOptions.ExecuteSynchronously);