final ArrayBlockingQueue queue = new ArrayBlockingQueue<Runnable>(10);
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(2, 4, 60, TimeUnit.MILLISECONDS, queue);

for (int i = 0; i < 161; i++) {
   final int index = i;
   threadPoolExecutor.execute(new Runnable() {
       @Override
       public void run() {
           System.out.println("index " + index + " queue size " + queue.size());
       }
   });
}