Java通过开启线程池实现多线程

benjamin77 2021-08-03 原文

计算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;
    }
}