Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // start and submit
- ExecutorService service = Executors.newFixedThreadPool(numThreads);
- for(Object[] row : results) service.submit(new BaseCheckDriver(row));
- // shutdown
- try{
- service.shutdown();
- service.awaitTermination(24, TimeUnit.HOURS);
- }catch(InterruptedException e){
- e.printStackTrace();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement