Skip to content

Commit 29dfa75

Browse files
committed
start callback threads as background thread.
1 parent fc66d2d commit 29dfa75

File tree

2 files changed

+9
-3
lines changed

2 files changed

+9
-3
lines changed

src/csharp/Microsoft.Spark/Broadcast.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -261,7 +261,7 @@ internal static void Remove(long bid)
261261
/// </summary>
262262
internal static class JvmBroadcastRegistry
263263
{
264-
[ThreadStatic]
264+
//[ThreadStatic]
265265
private static readonly List<JvmObjectReference> s_jvmBroadcastVariables =
266266
new List<JvmObjectReference>();
267267

src/csharp/Microsoft.Spark/Interop/Ipc/CallbackServer.cs

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,10 @@ internal void Run(ISocketWrapper listener)
121121
s_logger.LogInfo($"Started CallbackServer on {localEndPoint}");
122122

123123
// Start accepting connections from JVM.
124-
new Thread(() => StartServer(listener)).Start();
124+
new Thread(() => StartServer(listener))
125+
{
126+
IsBackground = true
127+
}.Start();
125128
}
126129
catch (Exception e)
127130
{
@@ -172,7 +175,10 @@ private void StartServer(ISocketWrapper listener)
172175
// waiting to take CallbackConnections from _waitingConnections).
173176
while (numWorkerThreads < numConnections)
174177
{
175-
new Thread(RunWorkerThread).Start();
178+
new Thread(RunWorkerThread)
179+
{
180+
IsBackground = true
181+
}.Start();
176182
++numWorkerThreads;
177183
}
178184

0 commit comments

Comments
 (0)