Looking for an example of a custom SynchronizationContext (Required for unit testing)

by

This one was written by me some time ago, no issues with copyright, no guarantees either(the system didn’t go into production):

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Windows.Threading;

namespace ManagedHelpers.Threads
{
    public class STASynchronizationContext : SynchronizationContext, IDisposable
    {
        private readonly Dispatcher dispatcher;
        private object dispObj;
        private readonly Thread mainThread;

        public STASynchronizationContext()
        {
            mainThread = new Thread(MainThread) { Name = "STASynchronizationContextMainThread", IsBackground = false };
            mainThread.SetApartmentState(ApartmentState.STA);
            mainThread.Start();

            //wait to get the main thread's dispatcher
            while (Thread.VolatileRead(ref dispObj) == null)
                Thread.Yield();

            dispatcher = dispObj as Dispatcher;
        }

        public override void Post(SendOrPostCallback d, object state)
        {
            dispatcher.BeginInvoke(d, new object[] { state });
        }

        public override void Send(SendOrPostCallback d, object state)
        {
            dispatcher.Invoke(d, new object[] { state });
        }

        private void MainThread(object param)
        {
            Thread.VolatileWrite(ref dispObj, Dispatcher.CurrentDispatcher);
            Console.WriteLine("Main Thread is setup ! Id = {0}", Thread.CurrentThread.ManagedThreadId);
            Dispatcher.Run();
        }

        public void Dispose()
        {
            if (!dispatcher.HasShutdownStarted && !dispatcher.HasShutdownFinished)
                dispatcher.BeginInvokeShutdown(DispatcherPriority.Normal);

            GC.SuppressFinalize(this);
        }

        ~STASynchronizationContext()
        {
            Dispose();
        }
    }
}

More Related Contents:

  1. If async-await doesn’t create any additional threads, then how does it make applications responsive?
  2. Task vs Thread differences [duplicate]
  3. Maximum number of threads in a .NET app?
  4. Attempted to read or write protected memory. This is often an indication that other memory is corrupt
  5. Multi-threaded splash screen in C#?
  6. Is it considered acceptable to not call Dispose() on a TPL Task object?
  7. Re-entrant locks in C#
  8. Getting the thread ID from a thread
  9. Multiple Parallel.ForEach loops in .Net
  10. What does SynchronizationContext do?
  11. Is there a way to indefinitely pause a thread?
  12. How to put a task to sleep (or delay) in C# 4.0?
  13. Task continuation on UI thread
  14. C# “internal” access modifier when doing unit testing
  15. Is it OK to use a string as a lock object?
  16. Async/Await vs Threads
  17. Monitor vs lock
  18. Unhandled exceptions in BackgroundWorker
  19. Proper way to Dispose of a BackGroundWorker
  20. EF Data Context – Async/Await & Multithreading
  21. Do I need to lock or mark as volatile when accessing a simple boolean flag in C#?
  22. Using Moq to determine if a method is called
  23. Why am I getting this error:”Cross-thread operation not valid: Control lbFolders accessed from a thread other than the thread it was created on.”?
  24. Can you link to a good example of using BackgroundWorker without placing it on a form as a component?
  25. Moq – Non-overridable members may not be used in setup / verification expressions
  26. How to correctly read an Interlocked.Increment’ed int field?
  27. ConcurrentDictionary Pitfall – Are delegates factories from GetOrAdd and AddOrUpdate synchronized?
  28. Should thread-safe class have a memory barrier at the end of its constructor?
  29. Async and Await with For Loop [duplicate]
  30. Calling an async method from a synchronous method

Leave a Comment