import java.util.concurrent.*;public class ThreadPoolTest2 {        public static void main(String[] args) {                int numWorkers = Integer.parseInt(args[0]);                ExecutorService tpes = Executors.newCachedThreadPool();                CallableWorkerThread workers[]  = new CallableWorkerThread[numWorkers];                Future futures[] = new Future[numWorkers];                                for (int i = 0; i < numWorkers; i++) {                        workers[i] = new CallableWorkerThread(i);                        futures[i]=tpes.submit(workers[i]);                }                for (int i = 0; i < numWorkers; i++) {                        try {                                        System.out.println("Ending worker: " + futures[i].get());                                } catch (Exception e) {}                }        }}