PrioThreadFactory.java

Go to the documentation of this file.

package org.openslx.imagemaster.serverconnection;

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

public class PrioThreadFactory implements ThreadFactory {

   private final AtomicInteger counter = new AtomicInteger();
   private final String name;
   private final int priority;

   public PrioThreadFactory(String name, int priority) {
      this.name = name;
      this.priority = priority;
   }

   @Override
   public Thread newThread(Runnable r) {
      Thread thread = new Thread(r, name + "-" + counter.incrementAndGet());
      thread.setPriority(priority);
      return thread;
   }

}