FutureTask的介绍和基本使用

作用：它定义了获取任务的执行结果，取消任务的执行，判断任务是否被取消，判断任务是否执行完毕等功能

为什么使用它？

我们先来举个例子

Thread thread=new Thread(（）->{
          .....
        },"thread");

这样的代码大家应该很熟悉，创建一个线程实例，里边用的Runnabel接口，这样虽然可以实现多线程，但是我们获取不到最后的执行结果，也不能取消任务的执行，所以就很lou，再看下边的图片

我们发现，Runnable刚好有一个子接口叫RunnableFuture，这个接口下有一个实现类实现了它，我们发现这个实现类是有这些功能的，所以我们是不是可以创建一个这样的实例对象去使用

就出现了下边的使用方式：

FutureTask futureTask=new FutureTask<String>(()->"我是你爸爸");
        Thread thread=new Thread(futureTask,"thread");
        thread.start();
        System.out.println(futureTask.get());
        System.out.println("我是你叔叔");

注意：FutureTask有两个构造方法，如下图，可以传一个Runnale接口实例，另一个参数就是返回值的类型，也就是FutureTask的泛型类型，也可以传一个callable接口，那FutureTask的泛型类型也就是call方法的返回值类型

创建线程池的几种方式

Executors.newSingleThreadExecutor

创建一个单线程的线程池，只有一条线程，如果线程因为异常而停止，会自动新建一个线程补充。

Executors.newFixedThreadPool

创建一个固定大小的线程池，因为采用无界的阻塞队列，所以实际线程数量永远不会变化，适用于负载较重的场景，对当前线程数量进行限制。（保证线程数可控，不会造成线程过多，导致系统负载更为严重）

Executors.newCachedThreadPool

用来创建一个可以无限扩大的线程池，适用于负载较轻的场景，执行短期异步任务。（可以使得任务快速得到执行，因为任务时间执行短，可以很快结束，也不会造成cpu过度切换）

Executors.newScheduledThreadPool

创建一个没有最大线程数限制的可以定时执行线程池，还有创建一个只有单个线程的可以定时执行线程池（Executors.newSingleThreadScheduledExecutor()）

Future利用线程池进行操作

public static void main(String[] args) {
//设置线程个数为三个
    ExecutorService executorService=Executors.newFixedThreadPool(3);
    FutureTask<String> futureTask=new FutureTask<String>(()->{
        System.out.println("正在执行代码线程池任务");
    },"ddfhfdjfhddj");
    executorService.submit(futureTask);
    System.out.println("正在执行主线程任务");
}

Future的弊端：

1.在调用get方法时，如果线程任务还没有执行完毕，会继续等待任务执行完毕，才返回，这样就会造成调用get方法下边的代码无法执行，造成阻塞，当然可以通过get方法的重载去设置最长等待时间，然后这样也只能解决一些简单的问题，所以可以通过以下轮训回调方法去判断，但是会造成cpu消耗严重

public static void main(String[] args) throws ExecutionException, InterruptedException {
    ExecutorService executorService=Executors.newFixedThreadPool(3);
    FutureTask<String> futureTask=new FutureTask<String>(()->{
        System.out.println("正在执行代码线程池任务");
    },"ddfhfdjfhddj");
    executorService.submit(futureTask);
    System.out.println("正在执行主线程任务");
    while (true){
        if (futureTask.isDone()){
            System.out.println("任务执行结果"+futureTask.get());
        }else {
            System.out.println("正在处理中别着急");
        }
    }
}1

cpu消耗问题解决