MessagePumpDispatcher

public class MessagePumpDispatcher : IDisposable
{
	private readonly ManualResetEventSlim _creatingThreadComplete;
	private readonly CancellationTokenSource _cancellationTokenSource;
	private readonly Thread _thread;

	private Dispatcher _dispatcher;

	public MessagePumpDispatcher()
	{
		_creatingThreadComplete = new ManualResetEventSlim(false);
		_cancellationTokenSource = new CancellationTokenSource();

		_thread = new Thread(RunThread);
		_thread.SetApartmentState(ApartmentState.STA);
		_thread.IsBackground = true;
		_thread.Start();
	}

	private void RunThread()
	{
		_dispatcher = Dispatcher.CurrentDispatcher;
		
		_creatingThreadComplete.Set();

		try
		{
			Dispatcher.Run();
		}
		catch (ThreadAbortException)
		{
			Thread.ResetAbort();
		}
	}

	public void Dispatch(Action action)
	{
		_creatingThreadComplete.Wait(_cancellationTokenSource.Token);
		_dispatcher.Invoke(action);
	}

	public Task<T> DispatchAsync<T>(Func<T> action)
	{
		_creatingThreadComplete.Wait(_cancellationTokenSource.Token);
		var result = _dispatcher.Invoke(action);
		return Task.FromResult(result);
	}
	public Task DispatchAsync(Action action)
	{
		_creatingThreadComplete.Wait(_cancellationTokenSource.Token);
		_dispatcher.Invoke(action);
		return Task.CompletedTask;
	}

	public void Dispose()
	{
		_cancellationTokenSource.Cancel();
		_thread.Abort();
	}
}