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         }

 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     }

 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)

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 }