Java线程池 / Executor / Callable / Future

为什么需要线程池？

每次都要new一个thread，开销大，性能差；不能统一管理；功能少（没有定时执行、中断等）。

使用线程池的好处是，可重用，可管理。

Executor

4种线程池

// 可缓存线程池,如果缓存中没有可用的，则移出60秒未使用过的线程

ExecutorService service= Executors.newCachedThreadPool();

// 大小固定的线程池

ExecutorService service= Executors.newFixedThreadPool(5);

// 单线程,是线程量=1的FixedThreadPool，多任务下相当于排队。

ExecutorService service= Executors.newSingleThreadPool();

// 支持定时和周期，一般情况下可替代timer

ScheduledExecutorService exec = Executors.newScheduledThreadPool(int corePoolSize)

Demo

ExecutorService pool= Executors.newCachedThredPool();

pool.ececute(new Runable());

// 关闭，不再接受新的任务请求

pool.shutdown();

// 立即关闭，停止接受task，

pool.showdownNow();

Future

.submit(Runnable) 返回一个Future，主要目的是检查任务执行的状况（是否完成，有无异常）。

interface Future<V>

{

V get() throws ...;

V get(long timeout,TimeUnit unit) throws ..;

void cancel(boolean mayInterrupt); // 取消任务，如果已经开始，mayInterrupt=true时被中断

boolean isCancelled();

boolean isDown();

}

Future task = pool.submit(new Runnable());

task.isDone(); //

task.get(); // 阻塞当前线程，如果task在执行过程中有异常，则会在这里重新抛出

Callable

Runnable没有返回值，Callable<E>有返回值；

submit一个runnable，不能知道运行结果，可以submit一个callable。

// 创建callable

class MyCallable implements Callable<Integer>

{

@Override

public Integer call()

{

return 1;

}

Future<Integer> task = pool.submit(new MyCallable());

task.get(); // 阻塞，显示结果

FutureTask

同时包装了Future和Task。

Callable<Integer> c = ...;

FutureTask<Integer> t = new FutureTask<Integer>(c);

new Thread(task).start();

Integer r = t.get();

CompletionService

completionService = new ExecutorCompletionService<Long>(exec);

for(){

completionService.submit(new Callable());

}

// 取完成的任务，如果没有，就阻塞等待

completionService.take().get()

转载于:https://www.cnblogs.com/caca/p/java_executors.html

Java线程池 / Executor / Callable / Future相关推荐

Java线程池Executor框架
一.为什么要引入线程池当存在大量并发任务时,创建.销毁线程需要很大的开销,运用线程池可以大大减小开销. 二.Executor框架说明: Executor 执行器接口,该接口定义执行Runnable ...
Java线程池(Executor)详解和用法
背景面试的时候经常会被三连问.用过吗?如何用的?场景是什么?所以有必要好好的研究下线程池迫在眉睫. 1.讲解之前先了解下 retry: 因为源码中有这个retry标记先看一个简单的例子 /*** ...
java 队列线程池_Java线程池Executor使用
原标题:Java线程池Executor使用合理利用线程池能够带来三个好处.第一:降低资源消耗.通过重复利用已创建的线程降低线程创建和销毁造成的消耗.第二:减少系统对于,外部服务的响应时间的等待.第 ...
深入Java线程池：从设计思想到源码解读
点击关注公众号,实用技术文章及时了解初识线程池我们知道,线程的创建和销毁都需要映射到操作系统,因此其代价是比较高昂的.出于避免频繁创建.销毁线程以及方便线程管理的需要,线程池应运而生. 线程池优势 ...
Java并发编程之线程池中的Future
线程池中的Future: 线程池的典型使用场景 ExecutorService executorService = Executors.newFixedThreadPool(10);//此处Task为 ...
java线程池拒绝策略_Java核心知识多线程并发线程池原理（二十三）
线程池做的工作主要是控制运行的线程的数量,处理过程中将任务放入队列,然后在线程创建后启动这些任务,如果线程数量超过了最大数量超出数量的线程排队等候,等其它线程执行完毕, 再从队列中取出任务来执行.他 ...
java 线程池ThreadPoolExecutor
线程池线程池的作用: 线程池作用就是限制系统中执行线程的数量. 根据系统的环境情况,可以自动或手动设置线程数量,达到运行的最佳效果:少了浪费了系统资源,多了造成系统拥挤效率不高.用线程池控制线程数 ...
Java 线程池详解
构造一个线程池为什么需要几个参数?如果避免线程池出现OOM?Runnable和Callable的区别是什么?本文将对这些问题一一解答,同时还将给出使用线程池的常见场景和代码片段. 基础知识 Execu ...
Java 线程池(ThreadPoolExecutor)原理分析与使用
ThreadPoolExecutor原理概述在我们的开发中"池"的概念并不罕见,有数据库连接池.线程池.对象池.常量池等等.下面我们主要针对线程池来一步一步揭开线程池的面纱. 使 ...

Java线程池 / Executor / Callable / Future

Java线程池 / Executor / Callable / Future相关推荐

最新文章

热门文章