建立執行緒的方式三:實現Callable介面
阿新 • • 發佈:2021-10-28
1 package com.atfu.java02; 2 3 import java.util.concurrent.Callable; 4 import java.util.concurrent.ExecutionException; 5 import java.util.concurrent.FutureTask; 6 7 /** 8 * 建立執行緒的方式三:實現Callable介面。----JDK5.0新增 9 * 10 * 如何理解實現Callable介面的方式建立多執行緒比實現Runable介面建立方式強大? 11 * 1.call()可以有返回值 12 * 2.call()可以丟擲異常此為本人學習筆記,若有錯誤,請不吝賜教13 * 3.callable是支援泛型的 14 * 15 * @author fu jingchao 16 * @creat 2021/10/28-12:59 17 */ 18 //1.建立一個實現callable的實現類 19 class NumThread implements Callable{ 20 //2.實現call(),將此執行緒需要執行的操作宣告在call()中, 21 @Override 22 public Object call() throws Exception { 23 int sum = 0; 24 for (int i = 1; i <= 100; i++) {25 if (i % 2 ==0){ 26 System.out.println(i); 27 sum += i; 28 } 29 } 30 return sum; 31 } 32 } 33 34 35 public class ThreadNew { 36 public static void main(String[] args) { 37 //3.建立callable介面實現類的物件 38 NumThread nt = newNumThread(); 39 //4.將此callable介面實現類的物件作為引數傳遞到FutureTask的構造器中,建立FutureTask的物件 40 FutureTask futureTask = new FutureTask(nt); 41 //5.將FutureTask的物件作為引數傳遞到Thread的構造器中,建立Thread物件,並呼叫start() 42 new Thread(futureTask).start(); 43 44 try { 45 //6.獲取callable中的call()的返回值 46 //get()返回值即為FutureTask構造器引數callable實現類重寫的call()的返回值 47 Object sum = futureTask.get(); 48 System.out.println("總和為:"+sum); 49 } catch (InterruptedException e) { 50 e.printStackTrace(); 51 } catch (ExecutionException e) { 52 e.printStackTrace(); 53 } 54 55 } 56 }