定義執行緒池：

private static ExecutorService executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() + 1,
    new ThreadFactory() {
        @Override
        public Thread newThread(Runnable r) {
            Thread thread = new Thread(r);
            thread.setName("TEST-THREAD"
 
);
            return new Thread(r);
        }
    });

定義執行緒：

private class TestThread implements Callable<Boolean> {

   private int id;

   public TestThread(int id) {
       this.id = id;
   }

   @Override
   public Boolean call() throws Exception {
       System.out.println("執行執行緒id：" + id);
       try
 
 {
           // TODO do something
       } catch (Exception e) {
           return Boolean.FALSE;
       }
       return Boolean.TRUE;
   }
}

test方法：

public static void main(String[] args) throws Exception {
   List<FutureTask<Boolean>> taskList = Lists.newArrayList();

   // 非同步執行
   for (int
 
 i = 0; i < 10; i++) {
       FutureTask<Boolean> ft = new FutureTask(new TestThread(i));
       taskList.add(ft);
       executor.submit(ft);
   }

   // TODO do something

   FutureTask<Boolean> ft;
   // 獲取非同步執行結果
   for (int i = 0; i < taskList.size(); i++) {
       ft = taskList.get(i);
       System.out.println("執行緒" + i + " 返回資料：" + ft.get());
   }
}