ThreadPool Exector異常処理
3104 ワード
java.util.co ncurrentパッケージの中のThreadPool Exectorは、java言語のスレッドプールを提供していますが、結果を返すタスク(submit)を提出してもいいです。Futreに戻るか、結果を返さないタスクを実行してもいいです。
1.submitのタスクに対して、フレームワークは異常をfutureに保持し、
2.executeのタスクに対応して、直接throwできます。例えば、Unicaght Exception Handlerを設定できます。
1.submitのタスクに対して、フレームワークは異常をfutureに保持し、
ExecutionException
に包装され、Future.get()を呼び出した場合、再度throwすると、ExecutionException.
getCause()を呼び出してパッケージのexceptionを取得することができます。この場合、ユニスティックエクスプローラを設定しても呼び出しられません。2.executeのタスクに対応して、直接throwできます。例えば、Unicaght Exception Handlerを設定できます。
import java.lang.Thread.UncaughtExceptionHandler;
import java.util.Random;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
public class ExecutorServiceDemo {
public static void testExecute() {
ExecutorService executors = new ThreadPoolExecutor(10, 20, 60, TimeUnit.SECONDS,
new LinkedBlockingQueue<Runnable>(), new ThreadFactory() {
final AtomicInteger threadNumber = new AtomicInteger(1);
public Thread newThread(Runnable r) {
Thread t = new Thread(Thread.currentThread().getThreadGroup(), r, "topPatternTasklet-thread"
+ (threadNumber.getAndIncrement()));
t.setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
public void uncaughtException(Thread t, Throwable e) {
System.out.println(e);
}
});
return t;
}
}, new ThreadPoolExecutor.CallerRunsPolicy());
final Random r = new Random();
for (int i = 0; i < 10; ++i) {
executors.execute(new Runnable() {
public void run() {
try {
int ri = r.nextInt(1000);
Thread.sleep(ri);
if (ri % 3 == 0) {
System.out.println("ri:" + ri);
throw new RuntimeException("haha error!");
}
System.out.println(Thread.currentThread());
} catch (InterruptedException e) {
}
}
});
}
executors.shutdown();
System.out.println("finished");
}
public static void main(String[] args) {
testExecute();
}
}