DefaultThreadFactory.scala

import java.util.concurrent.ThreadFactory
import java.util.concurrent.atomic.AtomicInteger

class DefaultThreadFactory(name: String) extends ThreadFactory {
  final private val group        = Thread.currentThread.getThreadGroup
  final private val threadNumber = new AtomicInteger(1)
  final private def threadName   = s"pool-$name-thread-${threadNumber.getAndIncrement}"

  def newThread(r: Runnable): Thread = {
    val t = new Thread(group, r, threadName, 0)
    if (t.isDaemon) t.setDaemon(false)
    if (t.getPriority != Thread.NORM_PRIORITY) t.setPriority(Thread.NORM_PRIORITY)
    t
  }
}