新增方式一：實現Callable介面

• 與使用Runnable相比，Callable功能更強大些
  • 相比run()方法，可以有返回值
  • 方法可以丟擲異常
  • 支援泛型的返回值
  • 需要藉助FutureTask類，比如獲取返回結果
• Future介面
  • 可以對具體Runnable、Callable任務的執行結果進行取消、查詢是否完成、獲取結果等。
  • FutureTask是Future介面的唯一的實現類
  • FutureTask同時實現了Runnable，Future介面。它既可以作為Runnable被執行緒執行，又可以作為Future得到Callable的返回值。

/*
建立執行緒的方式三：實現Callable介面。---JDK 5.0新增

如何理解實現Callable介面的方式建立多執行緒比實現Runnable介面建立多執行緒方式強大？
1.call()可以有返回值
2.call()可以丟擲異常，被外面的操作捕獲，獲取異常的資訊
3.Callable是支援泛型的
 */
//1.建立一個實現Callable的實現類
class NumThread implements Callable {
    //2.實現call方法，將此執行緒需要執行的操作宣告在call()方法中
    @Override
    public Object call() throws Exception {
        int sum = 0;
        for (int i = 0; i < 100; i++) {
            if (i%2 == 0){
                System.out.println(i);
                sum += i;
            }
        }
        return sum;
    }
}


public class ThreadNew {
    public static void main(String[] args) {
        //3.建立Callable介面的實現類的物件
        NumThread numThread = new NumThread();
        //4.將此Callable介面實現類的物件作為引數傳遞到FutureTask構造器中，建立FutureTask的物件
        FutureTask futureTask = new FutureTask(numThread);
        //5.將FutureTask 的物件作為引數傳遞到Thread類的構造器當中，建立Thread物件，並呼叫start()
        new Thread(futureTask).start();
        try {
            //6.獲取Callable 中call方法的返回值
            Object o = futureTask.get();
            System.out.println("綜合為"+o);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}
 

JDK5.0 新增執行緒建立方式

• 新增方式二：使用執行緒池
  • 背景：經常建立和銷燬、使用量特別大的資源，比如併發情況下的執行緒，對效能影響很大
  • 思路：提前建立好多個執行緒，放入執行緒池中，使用時直接獲取，使用完放回池中。可以避免頻繁建立銷燬、實現重複利用。類似生活中的公共交通工具。
  • 好處：
    • 提高響應速度（減少了建立新執行緒的時間）
    • 降低資源消耗（重複利用執行緒池中執行緒，不需要每次都建立）
    • 便於執行緒管理
      • corePoolSize:核心池的大小
      • maximumPoolSize:最大執行緒數
      • keepAliveTime:執行緒沒有任務是最多保持多長時間後會終止。
        

class NumberThread implements Runnable{
    @Override
    public void run() {
        for (int i = 0;i<100;i++){
            if (i%2==0){
                System.out.println(Thread.currentThread().getName()+":"+i);
            }
        }
    }
}
/*
建立執行緒的方式四：使用執行緒池
 */
public class ThreadPool {
    public static void main(String[] args) {
        //1.提供指定執行緒數量的執行緒池
        ExecutorService service = Executors.newFixedThreadPool(10);
        ThreadPoolExecutor service1 = (ThreadPoolExecutor) service;
        service1.getActiveCount();
        //2.執行指定的執行緒的操作。需要實現Runnable介面或Callable介面實現類的物件
        service.execute(new NumberThread());//適用於Runnable
//        service.submit();//適用於Callable
        service.shutdown();
    }
}s