From 71fe0daa08d97e1e4cf2bead7b943fd9ac0215e7 Mon Sep 17 00:00:00 2001
From: Christian Sailer <christian.sailer@r3.com>
Date: Tue, 24 Oct 2017 14:13:04 +0100
Subject: [PATCH] Give the checkpoint checker thread a meaningful name

---
 .../node/utilities/NamedThreadFactory.kt      | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)
 create mode 100644 node/src/main/kotlin/net/corda/node/utilities/NamedThreadFactory.kt

diff --git a/node/src/main/kotlin/net/corda/node/utilities/NamedThreadFactory.kt b/node/src/main/kotlin/net/corda/node/utilities/NamedThreadFactory.kt
new file mode 100644
index 0000000000..9b4044686c
--- /dev/null
+++ b/node/src/main/kotlin/net/corda/node/utilities/NamedThreadFactory.kt
@@ -0,0 +1,19 @@
+package net.corda.node.utilities
+
+import java.util.concurrent.ExecutorService
+import java.util.concurrent.Executors
+import java.util.concurrent.ThreadFactory
+import java.util.concurrent.atomic.AtomicInteger
+
+class NamedThreadFactory(private val name:String, private val underlyingFactory: ThreadFactory) : ThreadFactory{
+    val threadNumber = AtomicInteger(1)
+    override fun newThread(r: Runnable?): Thread {
+        val t = underlyingFactory.newThread(r)
+        t.name = name + "-" + threadNumber.getAndIncrement()
+        return t
+    }
+}
+
+fun newNamedSinleThreadExecutor(name: String): ExecutorService {
+    return Executors.newSingleThreadExecutor(NamedThreadFactory(name, Executors.defaultThreadFactory()))
+}