[C#] シングルスレッドで動く SynchronizationContext

SingleThreadSynchronizationContext.cs

/// <summary>
/// REF: https://blogs.msdn.microsoft.com/pfxteam/2012/01/20/await-synchronizationcontext-and-console-apps/
/// REF: https://qiita.com/ousttrue/items/66def43267329bc132ff
/// </summary>
internal sealed class SingleThreadSynchronizationContext : SynchronizationContext
{
    private readonly BlockingCollection<KeyValuePair<SendOrPostCallback, object>> _queue;

    public SingleThreadSynchronizationContext()
    {
        this._queue = new BlockingCollection<KeyValuePair<SendOrPostCallback, object>>();
    }

    public override void Post(SendOrPostCallback d, object state)
    {
        this._queue.Add(new KeyValuePair<SendOrPostCallback, object>(d, state));
    }

    public override void Send(SendOrPostCallback d, object state)
    {
        throw new NotSupportedException();
    }

    public void RunAll()
    {
        foreach (var item in this._queue.GetConsumingEnumerable())
        {
            item.Key(item.Value);
        }
    }

    public void Complete()
    {
        this._queue.CompleteAdding();
    }
}

usage.md

var context = new SingleThreadSynchronizationContext();

context.Post(...);
context.Post(...);
context.Post(...);

context.Complete();
context.RunAll();