Merge pull request #389 from OmniSharp/troy/sharedtestwriter

Update SharedTextWriter
OmniSharp · Feb 2, 2016 · 98bba51 · 98bba51
2 parents 06eabc8 + c2a54cf
commit 98bba51
Showing 1 changed file with 17 additions and 3 deletions.
diff --git a/src/OmniSharp.Stdio/Services/SharedTextWriter.cs b/src/OmniSharp.Stdio/Services/SharedTextWriter.cs
@@ -1,29 +1,43 @@
-using System.IO;
+using System.Collections.Concurrent;
+using System.IO;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace OmniSharp.Stdio.Services
 {
     public class SharedTextWriter : ISharedTextWriter
     {
+        private BlockingCollection<object> _queue = new BlockingCollection<object>();
+
         private readonly object _lock = new object();
         private readonly TextWriter _writer;
 
         public SharedTextWriter(TextWriter writer)
         {
             _writer = writer;
+
+            var thread = new Thread(() => { while (true) WriteLine(_queue.Take()); })
+            {
+                Name = $"{nameof(SharedTextWriter)} {nameof(BlockingCollection<object>)}",
+                IsBackground = true
+            };
+
+            thread.Start();
         }
 
         public void WriteLine(object value)
         {
-            lock(_lock)
+            lock (_lock)
             {
                 _writer.WriteLine(value);
             }
         }
 
         public Task WriteLineAsync(object value)
         {
-            return Task.Factory.StartNew(() => WriteLine(value));
+            _queue.Add(value);
+
+            return Task.FromResult(0);
         }
     }
 }