实现Callable接口

从Java5开始新增加创建线程的第三种方式为实现java.util.concurrent.Callable接口。

常用的方法如下：

package com.lagou.task18;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
/**
 * @author lijing
 * @date 2020/10/15 16:32
 * @description
 */
public class ThreadCallableTest implements Callable {
    @Override
    public Object call() throws Exception {
        //计算1~10000之间的累加和并打印
        int sum=0;
        for (int i = 1; i <= 10000; i++) {
            sum+=i;
        }
        System.out.println("计算的累加和是:"+sum);
        return sum;//自动装箱
    }
    public static void main(String[] args){
        ThreadCallableTest tct=new ThreadCallableTest();
        FutureTask ft=new FutureTask(tct);
        Thread t1=new Thread(ft);
        t1.start();
        Object obj=null;
        try {
             obj = ft.get();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
        System.out.println("线程处理犯法的返回值是:"+obj);
    }
}

FutureTask类

java.util.concurrent.FutureTask类用于描述可取消的异步计算，该类提供了Future接口的基本实现，包括启动和取消计算、查询计算是否完成以及检索计算结果的方法，也可以用于获取方法调用后的返回结果。
常用的方法如下：

线程池的由来

在服务器编程模型的原理，每一个客户端连接用一个单独的线程为之服务，当与客户端的会话结束时，线程也就结束了，即每来一个客户端连接，服务器端就要创建一个新线程。
如果访问服务器的客户端很多，那么服务器要不断地创建和销毁线程，这将严重影响服务器的性能。

概念和原理

线程池的概念：首先创建一些线程，它们的集合称为线程池，当服务器接受到一个客户请求后，就从线程池中取出一个空闲的线程为之服务，服务完后不关闭该线程，而是将该线程还回到线程池中。
在线程池的编程模式下，任务是提交给整个线程池，而不是直接交给某个线程，线程池在拿到任务后，它就在内部找有无空闲的线程，再把任务交给内部某个空闲的线程，任务是提交给整个线程池，一个线程同时只能执行一个任务，但可以同时向一个线程池提交多个任务。

相关类和方法

从Java5开始提供了线程池的相关类和接口：java.util.concurrent.Executors类java.util.concurrent.ExecutorService接口。
其中Executors是个工具类和线程池的工厂类，可以创建并返回不同类型的线程池，常用方法如
下：

其中ExecutorService接口是真正的线程池接口，主要实现类是ThreadPoolExecutor，常用方法
如下：

package com.lagou.task18;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
 * @author lijing
 * @date 2020/10/15 16:39
 * @description
 */
public class ThreadPoolTest {
    public static void main(String[] args) {
        //1.创建一个线程池
        ExecutorService executorService= Executors.newFixedThreadPool(10);
        //2.向线程池中布置任务
        executorService.submit(new ThreadCallableTest());
        //3.关闭线程池
    }
}