Merge pull request #995 from QuantConnect/lean-threads-background

Update all LEAN threads to be Background threads
QuantConnect · Jun 30, 2017 · 118d9aa · 118d9aa
2 parents 678b05b + 48fb380
commit 118d9aa
Show file tree

Hide file tree

Showing 6 changed files with 12 additions and 12 deletions.
diff --git a/Brokerages/Fxcm/FxcmBrokerage.cs b/Brokerages/Fxcm/FxcmBrokerage.cs
@@ -149,7 +149,7 @@ public override void Connect()
                             Log.Error(exception);
                         }
                     }
-                });
+                }) { IsBackground = true };
                 _orderEventThread.Start();
                 while (!_orderEventThread.IsAlive)
                 {
@@ -262,7 +262,7 @@ public override void Connect()
                     {
                         Log.Error(exception);
                     }
-                });
+                }) { IsBackground = true };
                 _connectionMonitorThread.Start();
                 while (!_connectionMonitorThread.IsAlive)
                 {

diff --git a/Brokerages/Oanda/OandaRestApiBase.cs b/Brokerages/Oanda/OandaRestApiBase.cs
@@ -220,7 +220,7 @@ public override void Connect()
                 {
                     Log.Error(exception);
                 }
-            });
+            }) { IsBackground = true };
             _connectionMonitorThread.Start();
             while (!_connectionMonitorThread.IsAlive)
             {

diff --git a/Common/RealTimeSynchronizedTimer.cs b/Common/RealTimeSynchronizedTimer.cs
@@ -39,7 +39,7 @@ public class RealTimeSynchronizedTimer
         public RealTimeSynchronizedTimer()
         {
             _period = TimeSpan.FromSeconds(0);
-            _thread = new Thread(Scanner);
+            _thread = new Thread(Scanner) { IsBackground = true };
         }
 
         /// <summary>
@@ -53,7 +53,7 @@ public RealTimeSynchronizedTimer(TimeSpan period, Action<DateTime> callback)
             _period = period;
             _callback = callback;
             _timer = new Stopwatch();
-            _thread = new Thread(Scanner);
+            _thread = new Thread(Scanner) { IsBackground = true };
             _stopped = false;
             _triggerTime = DateTime.UtcNow.RoundUp(period);
         }

diff --git a/Common/Util/ParallelRunner.cs b/Common/Util/ParallelRunner.cs
@@ -104,7 +104,7 @@ public void Start(CancellationToken token)
 
             }, CancellationToken.None);
 
-            _processQueueThread = new Thread(() => ProcessHoldQueue(token));
+            _processQueueThread = new Thread(() => ProcessHoldQueue(token)) { IsBackground = true };
             _processQueueThread.Start();
         }
 

diff --git a/Common/Util/ParallelRunnerWorker.cs b/Common/Util/ParallelRunnerWorker.cs
@@ -63,7 +63,7 @@ public void Start(CancellationToken token)
             lock (_sync)
             {
                 if (_thread != null) return;
-                _thread = new Thread(() => ThreadEntry(token));
+                _thread = new Thread(() => ThreadEntry(token)) { IsBackground = true };
                 _thread.Start();
             }
         }

diff --git a/Engine/Engine.cs b/Engine/Engine.cs
@@ -87,7 +87,7 @@ public void Run(AlgorithmNodePacket job, string assemblyPath)
 
             //Start monitoring the backtest active status:
             var statusPing = new StateCheck.Ping(algorithmManager, _systemHandlers.Api, _algorithmHandlers.Results, _systemHandlers.Notify, job);
-            var statusPingThread = new Thread(statusPing.Run);
+            var statusPingThread = new Thread(statusPing.Run) { IsBackground = true };
             statusPingThread.Start();
 
             try
@@ -105,7 +105,7 @@ public void Run(AlgorithmNodePacket job, string assemblyPath)
                 //-> Set the result handler type for this algorithm job, and launch the associated result thread.
                 _algorithmHandlers.Results.Initialize(job, _systemHandlers.Notify, _systemHandlers.Api, _algorithmHandlers.DataFeed, _algorithmHandlers.Setup, _algorithmHandlers.Transactions);
 
-                threadResults = new Thread(_algorithmHandlers.Results.Run, 0) {Name = "Result Thread"};
+                threadResults = new Thread(_algorithmHandlers.Results.Run, 0) { IsBackground = true, Name = "Result Thread" };
                 threadResults.Start();
 
                 IBrokerage brokerage = null;
@@ -227,9 +227,9 @@ public void Run(AlgorithmNodePacket job, string assemblyPath)
                     _algorithmHandlers.Results.SendStatusUpdate(AlgorithmStatus.Running);
 
                     //Launch the data, transaction and realtime handlers into dedicated threads
-                    threadFeed = new Thread(_algorithmHandlers.DataFeed.Run) {Name = "DataFeed Thread"};
-                    threadTransactions = new Thread(_algorithmHandlers.Transactions.Run) {Name = "Transaction Thread"};
-                    threadRealTime = new Thread(_algorithmHandlers.RealTime.Run) {Name = "RealTime Thread"};
+                    threadFeed = new Thread(_algorithmHandlers.DataFeed.Run) { IsBackground = true, Name = "DataFeed Thread" };
+                    threadTransactions = new Thread(_algorithmHandlers.Transactions.Run) { IsBackground = true, Name = "Transaction Thread" };
+                    threadRealTime = new Thread(_algorithmHandlers.RealTime.Run) { IsBackground = true, Name = "RealTime Thread" };
 
                     //Launch the data feed, result sending, and transaction models/handlers in separate threads.
                     threadFeed.Start(); // Data feed pushing data packets into thread bridge;