package com.atlassian.messagequeue.internal.core;
   
   import java.util.concurrent.ThreadFactory;
   import java.util.concurrent.atomic.AtomicInteger;
   
   /**
    * Thread factory.
    */
   public class DefaultThreadFactory implements ThreadFactory {
      private final AtomicInteger counter = new AtomicInteger(1);
      private final Thread.UncaughtExceptionHandler uncaughtExceptionHandler;
      private String threadNameTemplate;
  
      public DefaultThreadFactory(String threadNameTemplate, Thread.UncaughtExceptionHandler uncaughtExceptionHandler) {
          this.uncaughtExceptionHandler = uncaughtExceptionHandler;
          this.threadNameTemplate = threadNameTemplate;
      }
  
      @Override
      public Thread newThread(Runnable runnable) {
          final String name = String.format(threadNameTemplate, counter.getAndIncrement());
          final Thread thread = new Thread(runnable, name);
          thread.setUncaughtExceptionHandler(uncaughtExceptionHandler);
          return thread;
      }
  }