diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2018-01-30 15:29:33 +0100 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2018-01-30 15:41:54 +0100 |
commit | 083c31cb0eb18dce4f2a46d52b3606a92128230b (patch) | |
tree | a2e263b111b279128c1802c5333970f58656699e /kamon-core/src/main/scala/kamon/package.scala | |
parent | 4ab94c41bf5bd157d5ff1639ca5635ac5d98a3e4 (diff) | |
download | Kamon-083c31cb0eb18dce4f2a46d52b3606a92128230b.tar.gz Kamon-083c31cb0eb18dce4f2a46d52b3606a92128230b.tar.bz2 Kamon-083c31cb0eb18dce4f2a46d52b3606a92128230b.zip |
turn all Kamon threads into daemon threads, except for reporters, fixes #502
Diffstat (limited to 'kamon-core/src/main/scala/kamon/package.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/package.scala | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/kamon-core/src/main/scala/kamon/package.scala b/kamon-core/src/main/scala/kamon/package.scala index c746efa1..d3b25500 100644 --- a/kamon-core/src/main/scala/kamon/package.scala +++ b/kamon-core/src/main/scala/kamon/package.scala @@ -30,18 +30,19 @@ package object kamon { /** * Creates a thread factory that assigns the specified name to all created Threads. */ - def threadFactory(name: String): ThreadFactory = + def threadFactory(name: String, daemon: Boolean = false): ThreadFactory = new ThreadFactory { val defaultFactory = Executors.defaultThreadFactory() override def newThread(r: Runnable): Thread = { val thread = defaultFactory.newThread(r) thread.setName(name) + thread.setDaemon(daemon) thread } } - def numberedThreadFactory(name: String): ThreadFactory = + def numberedThreadFactory(name: String, daemon: Boolean = false): ThreadFactory = new ThreadFactory { val count = new AtomicLong() val defaultFactory = Executors.defaultThreadFactory() @@ -49,6 +50,7 @@ package object kamon { override def newThread(r: Runnable): Thread = { val thread = defaultFactory.newThread(r) thread.setName(name + "-" + count.incrementAndGet().toString) + thread.setDaemon(daemon) thread } } |