ThreadFactory with configurable priority.

PriorityThreadFactory.scala

package akka.dispatch

import java.util.concurrent.ThreadFactory

/**
 * Composition over the [[DispatcherPrerequisites.threadFactory]] that set priority for newly created threads.
 *
 * @param newThreadPriority priority that will be set to each newly created thread
 *                          should be between Thread.MIN_PRIORITY (which is 1) and Thread.MAX_PRIORITY (which is 10)
 */
class PriorityThreadFactory(prerequisites: DispatcherPrerequisites, newThreadPriority: Int) extends ThreadFactory {
  override def newThread(r: Runnable): Thread = {
    val newThread = prerequisites.threadFactory.newThread(r)
    newThread.setPriority(newThreadPriority)
    newThread
  }
}