Java/Threads/Executor

A simple example that uses an Executor.

 
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
class SimpExec {
  public static void main(String args[]) {
    CountDownLatch cdl = new CountDownLatch(5);
    CountDownLatch cdl2 = new CountDownLatch(5);
    CountDownLatch cdl3 = new CountDownLatch(5);
    CountDownLatch cdl4 = new CountDownLatch(5);
    ExecutorService es = Executors.newFixedThreadPool(2);
    es.execute(new MyThread(cdl, "A"));
    es.execute(new MyThread(cdl2, "B"));
    es.execute(new MyThread(cdl3, "C"));
    es.execute(new MyThread(cdl4, "D"));
    try {
      cdl.await();
      cdl2.await();
      cdl3.await();
      cdl4.await();
    } catch (InterruptedException exc) {
      System.out.println(exc);
    }
    es.shutdown();
  }
}
class MyThread implements Runnable {
  String name;
  CountDownLatch latch;
  MyThread(CountDownLatch c, String n) {
    latch = c;
    name = n;
    new Thread(this);
  }
  public void run() {
    for (int i = 0; i < 5; i++) {
      latch.countDown();
    }
  }
}