Part 9: java.util.concurrent : FixedThreadPool Example - JAVA

eader(dir.getAbsolutePath() + File.separator + file);
fileList.add(reader);
}
List> results = executorPool.invokeAll(fileList);
/**
* Check how many success and how many failure
*/
int success = 0, failure = 0;
for (Future result : results) {
if (result.get() == null) {
failure++;
} else {
success++;
}
}

System.out.println("Total number of files [" + fileList.size() + "]");
System.out.println("Success Count [" + success + "]");
System.out.println("Failure Count [" + failure + "]");
} else {
throw new IllegalArgumentException("There is no such directory name -" + directory);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
if (executorPool != null) {
executorPool.shutdown();
}
}
}
}

Part 9: java.util.concurrent : FixedThreadPool Example(二)