java1.5及1.6中通过ExecutorService提供了线程池的支持。我们可以按照如下的方法建立10个线程容量的线程池：
ExecutorService exec = Executors.newFixedThreadPool(10);
for (i = 0; i < taskAmount; i++)
exec.execute(new Task(...)); // 或者new Thread(...)
这样就把所有的任务提交给了线程池，由exec负责调度线程的执行，切换。
我们还应该加上下面一行代码：
exec.shutdown();
这样线程池在任务结束之后才会终止。我的问题是这样的：线程池的使用只是主线程的一个中间过程，而我必须等线程池中止之后才能继续后续的操作。所以我在上面的代码后面加上线程池中止判断语句，如果线程池仍在工作，主线程sleep。
while (!exec.isTerminated())
{
try
{
Thread.sleep(1000);
} catch (InterruptedException e)
{
e.printStackTrace();
}
}
可是我总觉得这不是最好的中止判断方式，至于哪里不好么……我也不清楚，只是觉得java应该提供更友好的接口，比如说可以让主线程等待线程池结束的方法，但是我没有找到。因此请教一下各路同道，有没有一种更好的方式实现呢？ 先行谢过哦…… 
==============================
public class MassTestClient {
/
private static int threadPoolSize = 10; // TODO configurable
private static String testCasesFile = "./service/client/config/pc/testCases.dat";
private static DateFormat dformat = new SimpleDateFormat("MM/dd/yyyy");
public static void main(String args[]) {
try {
....
ExecutorService exec = Executors.newFixedThreadPool(threadPoolSize, testClient.new TestClientThreadFactory());
List<String[]> list = readByBufferReader(testCasesFile);
for (String[] str : list) {
exec.execute(testClient.new testClientThread(tmlModule, str));
}
exec.shutdown()
;//Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. Invocation has no additional effect if already shut down.
//This method does not wait for previously submitted tasks to complete execution
while (!exec.isTerminated()) {
//Returns true if all tasks have completed following shut down.
// Note that isTerminated is never true unless either shutdown or shutdownNow was called first.
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("Execution complete");
} catch (Exception e) {
e.printStackTrace();
} finally {
System.exit(0);
}
}
private class testClientThread implements Runnable {
private String code;
private String id;
private String country;
private Date date;
private OPSTechModule module;
public testClientThread(OPSTechModule module, String[] str) throws Exception {
this.code = str[0];
this.id = str[1];
this.country = str[2];
this.date = dformat.parse(str[3]);
this.module = module;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + " " + code + "|" + id + "|" + country + "|" + date);
ISGSecurityDocument result = module.tmlSearch(code, id, country, date);
if (result != null)
System.out.println(result.toString());
}
}
private class TestClientThreadFactory implements ThreadFactory {
int counter = 0;
@Override
public Thread newThread(Runnable runnable) {
Thread thr = new Thread(runnable);
++counter;
thr.setName("testClient-" + counter);
return thr;
}
}
public static List<String[]> readByBufferReader(String file) {
List<String[]> list = new ArrayList<String[]>();
try {
BufferedReader br = new BufferedReader(new FileReader(new File(file)));
String line;
while ((line = br.readLine()) != null && !line.trim().isEmpty()) {
// System.out.println(line);
String str[] = line.trim().split("\|");
list.add(str);
}
br.close();
} catch (Exception ex) {
ex.printStackTrace();
}
return list;
}
}
版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/bincavin/article/details/8166659
站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。
