1 ScheduledExecutorService service = Executors.newScheduledThreadPool(10); 2 // 從現在開始delay毫秒之后,每隔一天執行一次,轉換為毫秒 3 // service.scheduleAtFixedRate(this, delay, period, TimeUnit.MILLISECONDS); 4 /**獲得線程中拋出的異常,eg Integer.parseInt("AAA");,缺少jar包等*/ 5 ScheduledFuture<?> future = service.scheduleAtFixedRate(this, delay, period, TimeUnit.MILLISECONDS); 6 try { 7 future.get(); 8 } catch (InterruptedException e) { 9 Throwable cause = e.getCause(); 10 //發送郵件 11 MailUtils.send("Write Data To HBase Faild", cause.getMessage()); 12 } catch (ExecutionException e) { 13 Throwable cause = e.getCause(); 14 //發送郵件 15 MailUtils.send("Write Data To HBase Faild", cause.getMessage()); 16 }
http://stackoverflow.com/questions/2459194/no-output-from-exception
exception example:
1 public class Playground { 2 3 /** 4 * @param args 5 */ 6 public static void main(String[] args) { 7 startThread(); 8 } 9 10 private static void startThread() { 11 ScheduledExecutorService timer = Executors 12 .newSingleThreadScheduledExecutor(); 13 Runnable r = new Runnable() { 14 int dummyInt = 0; 15 boolean dummyBoolean = false; 16 17 @Override 18 public void run() { 19 dummyInt = Integer.parseInt("AAAA"); 20 21 if (dummyBoolean) { 22 dummyBoolean= false; 23 } else { 24 dummyBoolean= true; 25 } 26 27 } 28 29 }; 30 31 timer.scheduleAtFixedRate(r, 0, 100, TimeUnit.MILLISECONDS); 32 33 }
How can I get it to?
I would expect to see this:
1 java.lang.NumberFormatException: For input string: "AAAA" 2 at java.lang.NumberFormatException.forInputString(Unknown Source) 3 at java.lang.Integer.parseInt(Unknown Source) 4 at java.lang.Integer.parseInt(Unknown Source) 5 at Playground$1.run(Playground.java:25) 6 at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) 7 at java.util.concurrent.FutureTask$Sync.innerRunAndReset(Unknown Source) 8 at java.util.concurrent.FutureTask.runAndReset(Unknown Source) 9 at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(Unknown Source) 10 at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(Unknown Source) 11 at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source) 12 at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) 13 at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) 14 at java.lang.Thread.run(Unknown Source)
The executor probably sets its own uncaught exception handler on the thread, so the stack trace won't be printed to the console. If an exception is thrown in the Runnable
you can get it from theScheduledFuture
object returned by the scheduleAtFixedRate
method:
1 ScheduledFuture<?> future = timer.scheduleAtFixedRate(r, 0, 100, TimeUnit.MILLISECONDS); 2 try { 3 future.get(); 4 } catch (ExecutionException e) { 5 Throwable cause = e.getCause(); 6 cause.printStackTrace(); 7 }