实现多线程的方式之实现Callable接口

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;
}
}
上一篇:Linux 设备驱动 Edition 3


下一篇:洛谷——P1451 求细胞数量