From 5d3459939012b65add792f989c6cbfdea483b5dd Mon Sep 17 00:00:00 2001 From: Carl Mastrangelo Date: Thu, 3 Sep 2015 14:51:09 -0700 Subject: [PATCH] Daemonize InProcess threads --- .../java/io/grpc/inprocess/InProcessTransport.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/core/src/main/java/io/grpc/inprocess/InProcessTransport.java b/core/src/main/java/io/grpc/inprocess/InProcessTransport.java index cabe58b4c7..2752e11798 100644 --- a/core/src/main/java/io/grpc/inprocess/InProcessTransport.java +++ b/core/src/main/java/io/grpc/inprocess/InProcessTransport.java @@ -85,7 +85,7 @@ class InProcessTransport implements ServerTransport, ClientTransport { if (serverTransportListener == null) { shutdownStatus = Status.UNAVAILABLE.withDescription("Could not find server: " + name); final Status localShutdownStatus = shutdownStatus; - new Thread(new Runnable() { + Thread shutdownThread = new Thread(new Runnable() { @Override public void run() { synchronized (InProcessTransport.this) { @@ -93,16 +93,22 @@ class InProcessTransport implements ServerTransport, ClientTransport { notifyTerminated(); } } - }).start(); + }); + shutdownThread.setDaemon(true); + shutdownThread.setName("grpc-inprocess-shutdown"); + shutdownThread.start(); } - new Thread(new Runnable() { + Thread readyThread = new Thread(new Runnable() { @Override public void run() { synchronized (InProcessTransport.this) { clientTransportListener.transportReady(); } } - }).start(); + }); + readyThread.setDaemon(true); + readyThread.setName("grpc-inprocess-ready"); + readyThread.start(); } @Override