make all thread pools create daemon threads

spring-attic · Nov 4, 2019 · 9a28cc3 · 9a28cc3
1 parent 492e8ae
commit 9a28cc3
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 0 deletions.
diff --git a/...n/java/org/springframework/cloud/gcp/autoconfigure/pubsub/GcpPubSubAutoConfiguration.java b/...n/java/org/springframework/cloud/gcp/autoconfigure/pubsub/GcpPubSubAutoConfiguration.java
@@ -116,6 +116,7 @@ public ThreadPoolTaskScheduler pubsubPublisherThreadPool() {
 		ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
 		scheduler.setPoolSize(this.gcpPubSubProperties.getPublisher().getExecutorThreads());
 		scheduler.setThreadNamePrefix("gcp-pubsub-publisher");
+		scheduler.setDaemon(true);
 		return scheduler;
 	}
 
@@ -132,6 +133,7 @@ public ThreadPoolTaskScheduler pubsubSubscriberThreadPool() {
 		ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
 		scheduler.setPoolSize(this.gcpPubSubProperties.getSubscriber().getExecutorThreads());
 		scheduler.setThreadNamePrefix("gcp-pubsub-subscriber");
+		scheduler.setDaemon(true);
 		return scheduler;
 	}
 
@@ -157,6 +159,7 @@ public Executor pubSubAcknowledgementExecutor() {
 		ThreadPoolTaskExecutor ackExecutor = new ThreadPoolTaskExecutor();
 		ackExecutor.setMaxPoolSize(this.gcpPubSubProperties.getSubscriber().getMaxAcknowledgementThreads());
 		ackExecutor.setThreadNamePrefix("gcp-pubsub-ack-executor");
+		ackExecutor.setDaemon(true);
 		return ackExecutor;
 	}
 

diff --git a/.../org/springframework/cloud/gcp/autoconfigure/trace/StackdriverTraceAutoConfiguration.java b/.../org/springframework/cloud/gcp/autoconfigure/trace/StackdriverTraceAutoConfiguration.java
@@ -127,6 +127,7 @@ public ThreadPoolTaskScheduler traceSenderThreadPool(GcpTraceProperties tracePro
 		ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
 		scheduler.setPoolSize(traceProperties.getNumExecutorThreads());
 		scheduler.setThreadNamePrefix("gcp-trace-sender");
+		scheduler.setDaemon(true);
 		return scheduler;
 	}
 

diff --git a/...java/org/springframework/cloud/gcp/autoconfigure/vision/CloudVisionAutoConfiguration.java b/...java/org/springframework/cloud/gcp/autoconfigure/vision/CloudVisionAutoConfiguration.java
@@ -102,6 +102,7 @@ public Executor cloudVisionExecutor() {
 		ThreadPoolTaskExecutor ackExecutor = new ThreadPoolTaskExecutor();
 		ackExecutor.setMaxPoolSize(this.cloudVisionProperties.getExecutorThreadsCount());
 		ackExecutor.setThreadNamePrefix("gcp-cloud-vision-ocr-executor");
+		ackExecutor.setDaemon(true);
 		return ackExecutor;
 	}