{"id":503,"date":"2012-01-21T16:49:00","date_gmt":"2012-01-21T16:49:00","guid":{"rendered":"https:\/\/blogs.msdn.microsoft.com\/pfxteam\/2012\/01\/21\/await-synchronizationcontext-and-console-apps-part-2\/"},"modified":"2012-01-21T16:49:00","modified_gmt":"2012-01-21T16:49:00","slug":"await-synchronizationcontext-and-console-apps-part-2","status":"publish","type":"post","link":"https:\/\/devblogs.microsoft.com\/dotnet\/await-synchronizationcontext-and-console-apps-part-2\/","title":{"rendered":"Await, SynchronizationContext, and Console Apps: Part 2"},"content":{"rendered":"

Yesterday, I blogged<\/a> about how you can implement a custom SynchronizationContext in order to pump the continuations used by async methods so that they may be processed on a single, dedicated thread.  I also highlighted that this is basically what UI frameworks like Windows Forms and Windows Presentation Foundation do with their message pumps.<\/p>\n

Now that we understand the mechanics of how these things work, it’s worth pointing out that we can achieve the same basic semantics without writing our own custom SynchronizationContext.  Instead, we can use one that already exists in the .NET Framework: DispatcherSynchronizationContext.  Through its Dispatcher class and its PushFrame<\/a> method, WPF provides the ability to (as described in MSDN) “enter an execute loop” that “processes pending work items.”  This is exactly what our custom SynchronizationContext was doing with its usage of BlockingCollection<T>, so we can just use WPF’s support instead of developing our own. (You might ask then why I started by describing how to do it manually and writing my own to exemplify it.  I do so because I think it’s important to really understand how things work; I typically find that developers write better higher-level code if they have the right mental model for what’s happening under the covers, allowing them to better reason about bugs, about performance, about reliability, and the like.)<\/p>\n

Below you can see how few lines of code it takes to achieve this support.  (To compile this code, you’ll need to reference WindowsBase.dll to bring in the relevant WPF types.)<\/p>\n

\n

using<\/span> System;
using<\/span> <\/span>System.Threading;
using<\/span> <\/span>System.Threading.Tasks;
using<\/span> <\/span>System.Windows.Threading; <\/p>\n

public static class<\/span> AsyncPump<\/span>
{
    public static void<\/span> Run(Func<\/span><Task<\/span>> func)
    {
        if<\/span> (func == null<\/span>) throw new<\/span> ArgumentNullException<\/span>(“func”<\/span>); <\/p>\n

        var<\/span> prevCtx = SynchronizationContext<\/span>.Current;
        try<\/span>
        {
            var<\/span> syncCtx = new<\/span> DispatcherSynchronizationContext<\/span>();
            SynchronizationContext<\/span>.SetSynchronizationContext(syncCtx); <\/p>\n

            var<\/span> t = func();
            if (t == null<\/span>) throw new <\/span>InvalidOperationException<\/span>(); <\/p>\n

            var <\/span>frame = new <\/span>DispatcherFrame<\/span>();
            t.ContinueWith(_ => { frame.Continue = false<\/span>; },
                TaskScheduler<\/span>.Default);
            Dispatcher<\/span>.PushFrame(frame); <\/p>\n

            t.GetAwaiter().GetResult();
        }
        finally<\/span>
        { 
            SynchronizationContext<\/span>.SetSynchronizationContext(prevCtx);
        }
    }
}<\/span><\/p>\n<\/blockquote>\n

In short, we instantiate a DispatcherSynchronizationContext and publish it to be Current on the current thread; this is what enables the awaits inside of the async method being processed to queue their continuations back to this thread and this thread’s Dispatcher.  Then we instantiate a DispatcherFrame, which represents an execute loop for WPF’s message pump.  We use a continuation to signal to that DispatcherFrame when it should exit its loop (i.e. when the Task completes).  And then we start the frame’s execute loop via the PushFrame method.<\/p>\n

All in all, just a few lines of code to achieve some powerful and useful behavior.<\/p><\/p>\n","protected":false},"excerpt":{"rendered":"

Yesterday, I blogged about how you can implement a custom SynchronizationContext in order to pump the continuations used by async methods so that they may be processed on a single, dedicated thread.  I also highlighted that this is basically what UI frameworks like Windows Forms and Windows Presentation Foundation do with their message pumps. Now […]<\/p>\n","protected":false},"author":360,"featured_media":58792,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[7908],"tags":[7907,7925,36,7909,7912],"class_list":["post-503","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-pfxteam","tag-net-4","tag-net-4-5","tag-async","tag-parallel-extensions","tag-task-parallel-library"],"acf":[],"blog_post_summary":"

Yesterday, I blogged about how you can implement a custom SynchronizationContext in order to pump the continuations used by async methods so that they may be processed on a single, dedicated thread.  I also highlighted that this is basically what UI frameworks like Windows Forms and Windows Presentation Foundation do with their message pumps. Now […]<\/p>\n","_links":{"self":[{"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/posts\/503","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/users\/360"}],"replies":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/comments?post=503"}],"version-history":[{"count":0,"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/posts\/503\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/media\/58792"}],"wp:attachment":[{"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/media?parent=503"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/categories?post=503"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/dotnet\/wp-json\/wp\/v2\/tags?post=503"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}