@Override
    public void run() {
      _priorityList.add(_priority);
      try {
        Thread.sleep(2000);
      } catch (InterruptedException e) {}
    }
Test Priority based thread pool executor.
test/com/linkedin/drelephant/priorityexecutor/PriorityBasedThreadPoolExecutorTest.java