gistfile1.java

ExecutorService threads = Executors.newCachedThreadPool();

for (final T elem : elements) {
  threads.submit(new Runnable() {
    @Override
    public void run() {
      operation.invoke(elem);
    }
  });
}

if (blocking) {
  threads.awaitTermination(long timeout, TimeUnit unit)
}