说我正在使用

ExecutorService ex = Executors.newFixedThreadPool(nrofthreads);


完成一些工作并等待完成。

但是我在工作线程中有相同的Threadlocal对象,批处理完成后需要关闭它们。
因此,我希望能够在线程池创建的所有工作线程上调用自定义的关闭方法。

最优雅的方法是什么?

现在,我正在使用的一种技巧是:

for(int i =0 ; i<20; i++){ //make sure to touch all threads with 20 runs..
   ex.execute(new Runnable(){
 public void run(){
   tearDownThreadLocals();
 }
   });
}
ex.shutdown();


但这对我来说似乎并不特别健壮;-)

谢谢
GJ

最佳答案

您可以使用Executors.newFixedThreadPool(int, ThreadFactory)传递ThreadFactory,如下所示:

ExecutorService ex = Executors.newFixedThreadPool(nrofthreads,
    new ThreadFactory() {
        public Thread newThread(final Runnable r) {
            return new Thread(new Runnable() {
                public void run() {
                    try {
                        r.run();
                    } finally {
                        tearDownThreadLocals();
                    }
                }
            });
        }
    });


编辑:刚注意到Executors已经有一个接受ThreadFactory的方法,因此无需显式创建ThreadPoolExecutor

10-06 09:15