使用Future

姜同学

发布于 2022-10-27 17:24:09

2660

发布于 2022-10-27 17:24:09

文章被收录于专栏：姜同学姜同学

在普通的Web项目开发过程中如果一个接口需要处理的任务比较多响应比较慢，就会很影响体验。我们通常的做法都是会新建一个线程去异步执行耗时的任务,以得到快速的响应。我们来回顾一下Java中创建线程的三种方式。

实现Runable接口之后虽然耗时的任务可以异步执行啦，但是对于有些任务我们难免需要获取它的返回值，这时候重新Runable接口获取返回值就比较复杂啦，但是不要慌我们还可以实现Callable接口重写call方法。但是问题来了我们怎样才能异步的获取call方法中的返回值呢。如果你经常使用线程池的话会发现ExecutorService.submit()这个方法可以把Callable作为参数传进去，然后返回一个叫做Future的东西。

看到这个方法之后如何获取call方法的返回值的答案就比较明显啦，那就是使用Future。

Future

很明显Future是个接口我们并不能直接使用，但是通过Future的类图我们又可以很快的定位到答案。

没错就是FutureTask.

FutureTask异步获取返回值

通过类图就看见FutureTask和Runable以及Future扯上关系了，和Callable毛关系也没有呀，别急，经常使用Spring框架的同学对于构造参数注入肯定不陌生，我们可以通过构造注入的方式将Callable传进来呀~

由此可见，这个FutureTask确实实现了Runable的特性是个异步的。我们在来康康它获取返回值的特性。

我们想要的返回值也拿到啦。但是很明显main线程被get方法阻塞了三秒没有立即返回效果又和同步执行区别不大了吗。

使用CompletableFuture

不过不要慌Future还有另外一个更加强大的是实现类CompletableFuture

CompletableFuture强在哪里了呢，强就强在它执行完上面四个静态方法之后可以有个回调方法不会阻塞住主线程。不信你往下看。

自定义一个线程池

public static ExecutorService customizeThreadPool(){
    BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>();
    ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
        .setNamePrefix("customize-thread-%s").build();

    int availableProcessors = Runtime.getRuntime().availableProcessors();
    // 计算密集型线程池
    int maximumPoolSize = availableProcessors + ;

    return new ThreadPoolExecutor(availableProcessors-, maximumPoolSize,
                                  , TimeUnit.SECONDS, workQueue,
                                  namedThreadFactory,
                                  new RejectedExecutionHandler() {
                                      @Override
                                      public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                                          throw new RejectedExecutionException("Queue full...");
                                      }
                                  });
}