From 28d9c465fd3f98977cdf9fdff4fa4123b68c27e1 Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Thu, 3 Sep 2020 09:22:55 +0800 Subject: [PATCH] --- src/org/redkale/util/ThreadHashExecutor.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/org/redkale/util/ThreadHashExecutor.java b/src/org/redkale/util/ThreadHashExecutor.java index 9c34741e8..8e956c8ff 100644 --- a/src/org/redkale/util/ThreadHashExecutor.java +++ b/src/org/redkale/util/ThreadHashExecutor.java @@ -27,8 +27,14 @@ public class ThreadHashExecutor { public ThreadHashExecutor(int size) { ExecutorService[] array = new ExecutorService[size]; + final AtomicInteger counter = new AtomicInteger(); for (int i = 0; i < array.length; i++) { - array[i] = Executors.newSingleThreadExecutor(); + array[i] = Executors.newSingleThreadExecutor((Runnable r) -> { + Thread t = new Thread(r); + t.setDaemon(true); + t.setName("Redkale-HashThread-" + counter.incrementAndGet()); + return t; + }); } this.executors = array; }