计算1..100 和1...200 的和,使用线程池开启两个线程
调用Executors类的newFixedThreadPool方法参数是线程池容纳的线程数量 这里是2 返回的对象是 ExecutorService类型
用返回的对象 调用submit方法,传入的参数可以是 实现接口类 Runnable 或者是 Callable<数据类型>
泛型里约束的 数据类型,是Callable实现类的重写方法 call方法的 返回值,通过这个返回值可以将运算的结果 返回输出
传入的实现类对象,返回值是一个 Featrue类的对象该类的泛型约束的数据类型和 实现类的泛型约束的数据格式一致
用该类的对象调用get方法即可获得所需要的计算结果返回值。
package demo06; import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future; /*
* 使用多线程技术,求和
* 两个线程,1个线程计算1..100和,另一个线程计算1..200的和
* 多线程的异步计算
*/
public class ThreadPoolDemo {
public static void main(String[] args) throws InterruptedException, ExecutionException {
ExecutorService es=Executors.newFixedThreadPool(2);
Future<Integer> f1=es.submit(new GetSumCallable(100));
Future<Integer> f2=es.submit(new GetSumCallable(200));
System.out.println(f1.get());
System.out.println(f2.get());
es.shutdown(); //销毁线程池,程序结束。不做这一步,程序将永久保持运行状态,资源得不到释放
}
}
package demo06; import java.util.concurrent.Callable; public class GetSumCallable implements Callable<Integer> {
private int a;
public GetSumCallable(int a){
this.a=a;
}
public Integer call(){
int sum=0;
for(int i=1;i<=a;i++){
sum+=i;
} return sum;
}
}