scheduler.java

package net.warmwaffles;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class Scheduler {
  private static Scheduler instance;

  private ThreadPoolExecutor executor;
  private LinkedBlockingQueue<Runnable> queue;

  public Scheduler() {
    int processors = Runtime.getRuntime().availableProcessors();
    queue = new LinkedBlockingQueue<Runnable>();
    executor = new ThreadPoolExecutor(processors, 10, 10, TimeUnit.SECONDS, queue);
  }

  public void schedule(Runnable runnable) {
    executor.execute(runnable);
  }

  public static void scheduleTask(Runnable runnable) {
    getInstance().schedule(runnable);
  }

  public static Scheduler getInstance() {
    if (instance == null) {
      instance = new Scheduler();
    }
    return instance;
  }
}