package com.hls.juc;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

/**
* 創建多線程的方式 : 4種
* 1.繼承Thread類
* 2.實現Runable接口
* 3.實現Callable接口
* 4.使用線程池創建線程
*
* Callable相比Runable的區別:
* 1. 線程任務有返回值
* 2. 需要使用FutureTask實現類接收返回值
* 3. futureTask.get方法獲取放回值時, 主線程會進入阻塞狀態, 等待分線程的完成
*/
public class CallableTest {
public static void main(String[] args) throws ExecutionException, InterruptedException {
long start = System.currentTimeMillis();
CallTask callTask = new CallTask();
//使用FutureTask實現類接收返回值 泛型是返回值類型
FutureTask <Integer> futureTask = new FutureTask <>(callTask);
// new Thread(futureTask).start();

for (int i = 0; i < 100; i++) {
new Thread(futureTask).start();
}

// 主線程會進入阻塞狀態, 等待分線程的完成 可以用于閉鎖
Integer sum = futureTask.get();
// System.out.println(sum);
long end = System.currentTimeMillis();
//計算程序消耗的時間 : 分線程全部執行完的時間 + 主線程的時間
System.out.println("程序消耗時間: " + (end - start));
}
}

//泛型是call方法的返回值
class CallTask implements Callable<Integer>{

@Override
public Integer call() throws Exception {
int sum = 0;
for (int i = 0; i < 100; i++) {
sum += i;
}
return sum;
}
}

轉載于:https://www.cnblogs.com/huangleshu/p/10028976.html

總結

以上是生活随笔為你收集整理的实现多线程的方式之实现Callable接口的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。