实现Callable接口创建线程

Callable接口是在jdk5版本中加入的，这个接口在java.util.concurrent包下面，与其他两种方式不同的地方在于使用Callable接口创建的线程会获得一个返回值并且可以声明异常。

使用Callable创建线程步骤：

1.自定义一个类实现java.util.concurrent包下的Callable接口2.重写call方法3.将要在线程中执行的代码编写在call方法中4.创建ExecutorService线程池5.将自定义类的对象放入线程池里面6.获取线程的返回结果7.关闭线程池，不再接收新的线程，未执行完的线程不会被关闭

package com.sutaoyu.Thread;import java.util.ArrayList;import java.util.concurrent.Callable;import java.util.concurrent.ExecutionException;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;class MyCallable implements Callable
     
      {    //睡眠时间    private long second;        //计算阶乘    private int count;        public MyCallable(int count, long second) {        this.count = count;        this.second = second;    }        //重写call方法    @Override    public Integer call() throws Exception {        // 3.将要执行的代码写在call方法中        // 计算阶乘        //让当前线程睡眠，单位是毫秒                Thread.sleep(second);        int sum = 1;        if(count == 0) {            sum = 0;        }else {            for(int i = 1;i <= count;i++) {                sum *= 1;            }        }                //打印线程名称        System.out.println(Thread.currentThread().getName() + "--------sum=" + sum);                return sum;    }    public int getCount() {        return count;    }    public void setCount(int count) {        this.count = count;    }}public class test_3 {        public static void main(String[] args) throws InterruptedException, ExecutionException {        //4.创建ExecutorService线程池        ExecutorService exec = Executors.newCachedThreadPool();                //5.创建存储Future对象的集合，用来存放ExecutorService的执行结果        ArrayList
      
       
        > results = new ArrayList
        
         
          >();                //6.开启2个线程，将返回的Future对象放入集合中        for(int i = 0;i < 2;i++) {            if(i == 0) {                //计算5的阶乘，睡眠10秒                results.add(exec.submit(new MyCallable(5, 10000)));            }else {                //计算3的阶乘，睡眠i秒                results.add(exec.submit(new MyCallable(3, i)));            }        }        for (Future
          
            fs : results) { //7.判断线程是否执行结束，如果执行结束就将结果打印 if (fs.isDone()) { System.out.println("计算结果:" + fs.get()); } else { System.out.println(fs.toString() + "该线程还没有计算完毕，请耐心等待"); } } //8.关闭线程池，不再接收新的线程，未执行完的线程不会被关闭 exec.shutdown(); System.out.println("main方法执行结束"); }}
          
         
        
       
      
     

线程池

线程池是初始化一个多线程应用程序过程中创建一个线程集合，然后在需要执行新的任务时直接去这个线程集合中获取，而不是创建一个线程。任务执行结束后，线程回到池子中等待下一次的分配。

线程池的作用

解决创建单个线程耗费时间和资源的问题。

创建线程池

上面代码中演示了两种方式创建线程池

• • Executors.newFixedThreadPool(int nThreads);
    通过传入的int类型参数来指定创建线程池中的线程数，如果任务6666666666666数量大于线程数量，则任务会进行等待。
  • Executors.newCachedThreadPool();
    会根据需要创建新线程的线程池，如果线程池中的线程数量小于任务数时，会创建新的线程，线程池中的线程最大数量是Integer.MAX_VALUE，int类型的最大值。如果线程的处理速度小于任务的提交速度时，会不断创建新的线程来执行任务，这样有可能会因为创建过多线程而耗尽CPU 和内存资源。