From 67a4f15659514288f287816b233ea92ae153c099 Mon Sep 17 00:00:00 2001
From: Simon Rettberg
Date: Mon, 19 Apr 2021 13:03:10 +0200
Subject: [daemon] Assign thread names, fine tune socket timeouts

---
 .../main/java/org/openslx/taskmanager/main/Taskmanager.java  | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

(limited to 'daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java')

diff --git a/daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java b/daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java
index 7b854c3..74fc1b7 100644
--- a/daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java
+++ b/daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java
@@ -6,8 +6,10 @@ import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.RejectedExecutionException;
 import java.util.concurrent.Semaphore;
+import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
 
 import org.apache.log4j.Logger;
 import org.openslx.taskmanager.Global;
@@ -27,7 +29,15 @@ public class Taskmanager implements FinishCallback, Runnable
 	private static final Logger log = Logger.getLogger( Taskmanager.class );
 
 	private final ThreadPoolExecutor threadPool = new ThreadPoolExecutor( 8, 32, 1, TimeUnit.MINUTES,
-			new ArrayBlockingQueue<Runnable>( 4 ) );
+			new ArrayBlockingQueue<Runnable>( 4 ), new ThreadFactory() {
+				AtomicInteger id = new AtomicInteger();
+
+				@Override
+				public Thread newThread( Runnable r )
+				{
+					return new Thread( r, "Task-" + id.incrementAndGet() );
+				}
+			} );
 
 	/**
 	 * gson object for (de)serialization
-- 
cgit v1.2.3-55-g7522