ThreadPoolDemo.java

public class ThreadPoolDemo {
	
	public static void main(String[] args) {
		
		ExecutorService service = Executors.newFixedThreadPool(2);
		for(int i =0;i<5;i++){
			service.execute(new Processor());
//			Future f =service.submit(new Processor());
		}
		service.shutdown();
	}
	
	

}

class Processor implements Runnable{

	@Override
	public void run() {
		System.out.println("Starting "+Thread.currentThread());
		try {
			Thread.sleep(5000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println("Completed" +Thread.currentThread());
		
	}
	
}