特定のSynchronizationContextに投稿されるタスクを作成するにはどうすればよいですか？

Question

既にこのコンテキストに投稿されているTaskを作成するにはどうすればいいですか（これは基本的には特定のスレッドのウィンドウです）SynchronizationContextがあるとします。

参考のために、ここにはSynchronizationContextの設定方法のデモンストレーション非常に基本的なのデモンストレーションがあります。

public class SomeDispatcher : SynchronizationContext 
{ 
    SomeDispatcher() { 

     new Thread(() => { 

      SynchronizationContext.SetSynchronizationContext(this); 

      // Dispatching loop (among other things) 

     }).Start(); 
    } 

    override void Post(SendOrPostCallback d, object state) 
    { 
     // Add (d, state) to a dispatch queue; 
    } 
} 

非同期/がすでにコンテキストで実行されているを待っためにこれが正常に動作します。

ここでは、外部のコンテキスト（UIスレッドなど）からTaskをこれに投稿できるようにしたいが、これを行うためのきれいな方法を見つけることはできないようだ。

これを行う1つの方法は、TaskCompletionSource<>を使用することです。

Task StartTask(Action action) 
{ 
    var tcs = new TaskCompletionSource<object>(); 
    SaidDispatcher.Post(state => { 
     try 
     { 
      action.Invoke(); 
      tcs.SetResult(null); 
     } 
     catch (Exception ex) 
     { 
      tcs.SetException(ex); 
     } 
    }); 
    return tcs.Task; 
}); 

しかし、これはSynchronizationContextからTaskFactoryインタフェースは、理想的には、おそらく

などホイールとバリエーションなどStartNew(Func<TResult>)、StartNew(Func<Task<TResult>>)を支える主要な痛みを、再発明されていますが、私は1つのインスタンスを作成するように見えることはできませんきれい：

TaskFactory CreateTaskFactory() 
{ 
    var original = SynchronizationContext.Current; 
    SynchronizationContext.SetSynchronizationContext(SomeDispatcher); // yuck! 
    try 
    { 
     return new TaskFactory(TaskScheduler.FromCurrentSynchronizationContext()); 
    } 
    finally 
    { 
     SynchronizationContext.SetSynchronizationContext(original); 
    } 
} 

（。つまり、現在のスレッドの同期コンテキストはハックと思われる一時的なホースを有する）

Answer 1

これはデフォルトSynchronizationContextTaskSchedulerのみ現在の同期コンテキスト

で動作します。しかし、それはソースコードだ

内部

1. あるらしい提供されていますhere、我々は、それは比較的簡単ですので、我々はロールしようとすることができます参照してください

   public sealed class MySynchronizationContextTaskScheduler : TaskScheduler { 
       private readonly SynchronizationContext _synchronizationContext; 
   
       public MySynchronizationContextTaskScheduler(SynchronizationContext context) { 
        _synchronizationContext = context; 
       } 
   
       [SecurityCritical] 
       protected override void QueueTask(Task task) { 
        _synchronizationContext.Post(PostCallback, task); 
       } 
   
       [SecurityCritical] 
       protected override bool TryExecuteTaskInline(Task task, bool taskWasPreviouslyQueued) { 
        if (SynchronizationContext.Current == _synchronizationContext) { 
         return TryExecuteTask(task); 
        } 
        else 
         return false; 
       } 
   
       [SecurityCritical] 
       protected override IEnumerable<Task> GetScheduledTasks() { 
        return null; 
       } 
   
       public override Int32 MaximumConcurrencyLevel 
       { 
        get { return 1; } 
       } 
   
       private void PostCallback(object obj) { 
        Task task = (Task) obj; 
        base.TryExecuteTask(task); 
       } 
   } 
   

   次に、あなたのCreateTaskFactoryは次のようになります。

   TaskFactory CreateTaskFactory() { 
       return new TaskFactory(new MySynchronizationContextTaskScheduler(SomeDispatcher)); 
   } 
   

   そして、あなたがしてタスクを作成します。正確に何をしたいん

   var factory = CreateTaskFactory(); 
   var task = factory.StartNew(...); 
   

Answer 2

Parallel Extensions Extras contains SynchronizationContextTaskScheduler。

自分でPEEをコンパイルしたくない場合はthere is an unofficial NuGet package for itです。

通常、これを行う必要はないはずですが、これを求めているという事実はデザインの欠陥を示している可能性があります。