File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
src/csharp/Microsoft.Spark/Interop/Ipc Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -121,7 +121,10 @@ internal void Run(ISocketWrapper listener)
121
121
s_logger . LogInfo ( $ "Started CallbackServer on { localEndPoint } ") ;
122
122
123
123
// Start accepting connections from JVM.
124
- new Thread ( ( ) => StartServer ( listener ) ) . Start ( ) ;
124
+ new Thread ( ( ) => StartServer ( listener ) )
125
+ {
126
+ IsBackground = true
127
+ } . Start ( ) ;
125
128
}
126
129
catch ( Exception e )
127
130
{
@@ -172,7 +175,10 @@ private void StartServer(ISocketWrapper listener)
172
175
// waiting to take CallbackConnections from _waitingConnections).
173
176
while ( numWorkerThreads < numConnections )
174
177
{
175
- new Thread ( RunWorkerThread ) . Start ( ) ;
178
+ new Thread ( RunWorkerThread )
179
+ {
180
+ IsBackground = true
181
+ } . Start ( ) ;
176
182
++ numWorkerThreads ;
177
183
}
178
184
You can’t perform that action at this time.
0 commit comments