{"id":4061,"date":"2015-07-01T13:00:34","date_gmt":"2015-07-01T13:00:34","guid":{"rendered":"http:\/\/writeasync.net\/?p=4061"},"modified":"2015-07-01T04:17:01","modified_gmt":"2015-07-01T04:17:01","slug":"the-battle-of-async-methods","status":"publish","type":"post","link":"http:\/\/writeasync.net\/?p=4061","title":{"rendered":"The battle of async methods"},"content":{"rendered":"

In a contest between async proper, Task.Run<\/a>, and dedicated threads, who will win? Let’s gather some data points for a specific scenario and find out!<\/p>\n

Today’s benchmark will make use of a trivial single process WCF named pipes<\/a> application using .NET 4.5. The complete source code is as follows:<\/p>\n

\r\nnamespace AsyncPerf\r\n{\r\n    using System;\r\n    using System.Collections.Generic;\r\n    using System.Reflection;\r\n    using System.ServiceModel;\r\n    using System.ServiceModel.Description;\r\n    using System.Threading;\r\n    using System.Threading.Tasks;\r\n\r\n    internal sealed class Program\r\n    {\r\n        private static readonly Uri BaseAddress = new Uri("net.pipe:\/\/localhost\/TestService");\r\n\r\n        private static void Main(string[] args)\r\n        {\r\n            if (args.Length != 4)\r\n            {\r\n                Console.WriteLine("Provide the task count, message count, operation delay (ms), and method name.");\r\n                return;\r\n            }\r\n\r\n            int senderCount = int.Parse(args[0]);\r\n            int messageCount = int.Parse(args[1]);\r\n            TimeSpan delay = TimeSpan.FromMilliseconds(int.Parse(args[2]));\r\n            MethodInfo method = typeof(AsyncMethods).GetMethod(args[3]);\r\n            Func<int, Task> func = (Func<int, Task>)method.CreateDelegate(typeof(Func<int, Task>));\r\n\r\n            ServiceHost host = new ServiceHost(new TestService(delay), BaseAddress);\r\n            ServiceThrottlingBehavior throttlingBehavior = new ServiceThrottlingBehavior\r\n            {\r\n                MaxConcurrentCalls = int.MaxValue,\r\n                MaxConcurrentInstances = int.MaxValue,\r\n                MaxConcurrentSessions = int.MaxValue,\r\n            };\r\n            host.Description.Behaviors.Add(throttlingBehavior);\r\n            host.AddServiceEndpoint(typeof(ITestService), GetBinding(), string.Empty);\r\n            host.Open();\r\n\r\n            List<Task> tasks = new List<Task>();\r\n            for (int i = 0; i < senderCount; ++i)\r\n            {\r\n                tasks.Add(func(messageCount));\r\n            }\r\n\r\n            Task.WaitAll(tasks.ToArray());\r\n        }\r\n\r\n        private static NetNamedPipeBinding GetBinding()\r\n        {\r\n            return new NetNamedPipeBinding(NetNamedPipeSecurityMode.None);\r\n        }\r\n\r\n        [ServiceContract(Name = "ITestService")]\r\n        private interface ITestServiceLegacyAsync\r\n        {\r\n            [OperationContract(AsyncPattern = true)]\r\n            IAsyncResult BeginIncrement(int input, AsyncCallback callback, object state);\r\n\r\n            int EndIncrement(IAsyncResult result);\r\n        }\r\n\r\n        [ServiceContract(Name = "ITestService")]\r\n        private interface ITestServiceTaskAsync\r\n        {\r\n            [OperationContract(AsyncPattern = true)]\r\n            Task<int> IncrementAsync(int input);\r\n        }\r\n\r\n        [ServiceContract]\r\n        private interface ITestService\r\n        {\r\n            [OperationContract]\r\n            int Increment(int input);\r\n        }\r\n\r\n        [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)]\r\n        private sealed class TestService : ITestService\r\n        {\r\n            private readonly TimeSpan delay;\r\n\r\n            public TestService(TimeSpan delay)\r\n            {\r\n                this.delay = delay;\r\n            }\r\n\r\n            public int Increment(int input)\r\n            {\r\n                Thread.Sleep(delay);\r\n                return input + 1;\r\n            }\r\n        }\r\n\r\n        private static class AsyncMethods\r\n        {\r\n            public static async Task SendTaskRunAsync(int count)\r\n            {\r\n                ITestService proxy = ChannelFactory<ITestService>.CreateChannel(GetBinding(), new EndpointAddress(BaseAddress));\r\n                int i = 0;\r\n                while (i < count)\r\n                {\r\n                    i = await Task.Run(() => proxy.Increment(i));\r\n                }\r\n            }\r\n\r\n            public static Task SendThreadAsync(int count)\r\n            {\r\n                Action action = delegate\r\n                {\r\n                    ITestService proxy = ChannelFactory<ITestService>.CreateChannel(GetBinding(), new EndpointAddress(BaseAddress));\r\n                    int i = 0;\r\n                    while (i < count)\r\n                    {\r\n                        i = proxy.Increment(i);\r\n                    }\r\n                };\r\n\r\n                return Task.Factory.StartNew(action, TaskCreationOptions.LongRunning);\r\n            }\r\n\r\n            public static async Task SendLegacyTask2Async(int count)\r\n            {\r\n                ITestServiceLegacyAsync proxy = ChannelFactory<ITestServiceLegacyAsync>.CreateChannel(GetBinding(), new EndpointAddress(BaseAddress));\r\n                int i = 0;\r\n                while (i < count)\r\n                {\r\n                    i = await Task.Factory.FromAsync(\r\n                        (a, c, s) => ((ITestServiceLegacyAsync)s).BeginIncrement(a, c, s),\r\n                        r => ((ITestServiceLegacyAsync)r.AsyncState).EndIncrement(r),\r\n                        i,\r\n                        proxy);\r\n                }\r\n            }\r\n\r\n            public static async Task SendLegacyTaskAsync(int count)\r\n            {\r\n                ITestServiceLegacyAsync proxy = ChannelFactory<ITestServiceLegacyAsync>.CreateChannel(GetBinding(), new EndpointAddress(BaseAddress));\r\n                int i = 0;\r\n                while (i < count)\r\n                {\r\n                    i = await Task.Factory.FromAsync(\r\n                        (c, s) => proxy.BeginIncrement(i, c, s),\r\n                        r => proxy.EndIncrement(r),\r\n                        null);\r\n                }\r\n            }\r\n\r\n            public static async Task SendRealTaskAsync(int count)\r\n            {\r\n                ITestServiceTaskAsync proxy = ChannelFactory<ITestServiceTaskAsync>.CreateChannel(GetBinding(), new EndpointAddress(BaseAddress));\r\n                int i = 0;\r\n                while (i < count)\r\n                {\r\n                    i = await proxy.IncrementAsync(i);\r\n                }\r\n            }\r\n        }\r\n    }\r\n}\r\n<\/pre>\n
(Note the service throttling settings<\/a>, which will prevent us from hitting any artificial concurrency limits.)<\/p>\n
We have five different algorithms in the runnings:<\/p>\n
    \n
  1. SendRealTaskAsync: Uses a Task-based async contract to send messages.<\/li>\n
  2. SendLegacyTaskAsync: Uses a legacy asynchronous programming model contract wrapped on the outside by Task.Factory.FromAsync<\/a>.<\/li>\n
  3. SendLegacyTask2Async: Same as SendLegacyTaskAsync except using a different overload of Task.Factory.FromAsync<\/a> which avoids the use of a generated closure.<\/li>\n
  4. SendThreadAsync: Uses a synchronous contract and offloads the entire send loop to a new thread.<\/li>\n
  5. SendTaskRunAsync: Uses a synchronous contract wrapped on the outside with Task.Run.<\/li>\n<\/ol>\n
    All measurements were taken on a Surface Pro 3<\/a> i7 model (quad core, 1.7-3.3 GHz, 8 GB RAM).<\/p>\n
    Contest 1: 1000 concurrent senders, no server-side delay<\/h2>\n
    In the first contest, we will compare performance without any server delay at all, i.e. the message responses arrive as fast as possible.<\/p>\n
    \"SendLegacyTask2Async\"<\/a>
    SendLegacyTask2Async<\/p><\/div>\n
    \"SendLegacyTaskAsync\"<\/a>
    SendLegacyTaskAsync<\/p><\/div>\n
    \"SendRealTaskAsync\"<\/a>
    SendRealTaskAsync<\/p><\/div>\n
    \"SendTaskRunAsync\"<\/a>
    SendTaskRunAsync<\/p><\/div>\n
    \"SendThreadAsync\"<\/a>
    SendThreadAsync<\/p><\/div>\n
    Clearly, dedicated threads are bad for such a high degree of concurrency. But what is this? Task.Run seems to outperform the genuine Task-based async contract. While this may at first be a shock, consider the fact that there is no server delay. Hence, the completion time of an operation here is going to be nearly as fast as a local method call. The amount of thread switching and async overhead does not pay off in this case.<\/p>\n
    Contest 2: 1000 concurrent senders, 100 ms server-side delay<\/h2>\n
    In the next contest, we introduce 100 ms of delay on the message responses.<\/p>\n
    \"SendLegacyTask2Async\"<\/a>
    SendLegacyTask2Async<\/p><\/div>\n
    \"SendLegacyTaskAsync\"<\/a>
    SendLegacyTaskAsync<\/p><\/div>\n
    \"SendRealTaskAsync\"<\/a>
    SendRealTaskAsync<\/p><\/div>\n
    \"SendTaskRunAsync\"<\/a>
    SendTaskRunAsync<\/p><\/div>\n
    \"SendThreadAsync\"<\/a>
    SendThreadAsync<\/p><\/div>\n
    Dedicated threads lose, as expected. We didn’t even get to the point where all threads were even active given the various delays in creation of new thread pool threads and the total thread count limit. Real task-based async is on par with SendLegacyTask2Async and a bit better than SendLegacyTaskAsync as expected. For a more proper comparison, it might have been prudent to also implement server-side async (this is partially why the threads seem to be growing to such a high amount) — but the general trend is relatively clear nonetheless.<\/p>\n
    Conclusion? When the operations being performed are basically CPU-bound, the overhead of async might give you pause. However, in a more realistic situation where most I\/O time is spent waiting around, tasks do the trick quite well.<\/p>\n","protected":false},"excerpt":{"rendered":"
    In a contest between async proper, Task.Run, and dedicated threads, who will win? Let’s gather some data points for a specific scenario and find out! Today’s benchmark will make use of a trivial single process WCF named pipes application using… <\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[21,61,71],"tags":[],"class_list":["post-4061","post","type-post","status-publish","format-standard","hentry","category-async","category-concurrency","category-diagnostics"],"_links":{"self":[{"href":"http:\/\/writeasync.net\/index.php?rest_route=\/wp\/v2\/posts\/4061","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/writeasync.net\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/writeasync.net\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/writeasync.net\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/writeasync.net\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=4061"}],"version-history":[{"count":0,"href":"http:\/\/writeasync.net\/index.php?rest_route=\/wp\/v2\/posts\/4061\/revisions"}],"wp:attachment":[{"href":"http:\/\/writeasync.net\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=4061"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/writeasync.net\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=4061"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/writeasync.net\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=4061"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}