JDK源码分析之concurrent包(一) -- Executor架构
2015-07-06 00:13
447 查看
Java5新出的concurrent包中的API,是一些并发编程中实用的的工具类。在高并发场景下的使用非常广泛。笔者在这做了一个针对concurrent包中部分常用类的源码分析系列。本系列针对的读者是已经对并发包中的Executor框架和工具类有所了解并懂得如何使用的人群,如果对并发包还不了解的朋友,请先做些了解。网上对这方面的讲述有丰富的资源。
本篇博文是第一期,首先对Executor架构做一个概述。这里只简单介绍接口和类的继承、使用关系。
盗用一张类图来描述结构:
ExecutorService是Executor的扩展接口,主要扩展了执行Runnable或Callable任务的方式,及shutdown的方法;
ScheduledExecutorService是ExecutorService的扩展接口,主要扩展了可以用任务调度的形式(延迟或定期)执行Runnable或Callable任务;
AbstractExecutorService是ExecutorService接口的实现类,是抽象类,提供一些默认的执行Runnable或Callable任务的方法;
ThreadPoolExecutor是AbstractExecutorService的子类,是线程池的实现;
ScheduledThreadPoolExecutor是ThreadPoolExecutor的子类,实现ScheduledExecutorService接口,基于线程池模式的多任务调度,是Timer工具类的高性能版;
Callable与Future是Runnable的另外的形式,用来异步获取任务执行结果;
最后,Executors是工具类,用于创建上述各种实例。
此外,CompletionService接口可以认为是Executor的一个分支,注意这里CompletionService并不是Executor的子接口,上图可能会让部分读者产生歧义。CompletionService是用来将生产新的异步任务与使用已完成任务的结果分离开来的服务。基于Executor的任务执行,与Future搭配使用。
对Executor框架的结构做了简单的描述之后,接下来就要进入源码解析的正篇部分了。这里笔者计划重点对框架中的ThreadPoolExecutor、FutureTask及一些工具类如Exchanger、CountDownLatch、CyclicBarrier、Semaphore和几个常用的并发集合如ArrayBlockingQueue、ConcurrentLinkedQueue、ConcurrentHashMap、CopyOnWriteArrayList做分析。
一个人的理解难免有片面和遗漏,还望各位海涵和指正。
本篇博文是第一期,首先对Executor架构做一个概述。这里只简单介绍接口和类的继承、使用关系。
盗用一张类图来描述结构:
解析:
Executor是总的接口,用来执行Runnable任务;ExecutorService是Executor的扩展接口,主要扩展了执行Runnable或Callable任务的方式,及shutdown的方法;
ScheduledExecutorService是ExecutorService的扩展接口,主要扩展了可以用任务调度的形式(延迟或定期)执行Runnable或Callable任务;
AbstractExecutorService是ExecutorService接口的实现类,是抽象类,提供一些默认的执行Runnable或Callable任务的方法;
ThreadPoolExecutor是AbstractExecutorService的子类,是线程池的实现;
ScheduledThreadPoolExecutor是ThreadPoolExecutor的子类,实现ScheduledExecutorService接口,基于线程池模式的多任务调度,是Timer工具类的高性能版;
Callable与Future是Runnable的另外的形式,用来异步获取任务执行结果;
最后,Executors是工具类,用于创建上述各种实例。
此外,CompletionService接口可以认为是Executor的一个分支,注意这里CompletionService并不是Executor的子接口,上图可能会让部分读者产生歧义。CompletionService是用来将生产新的异步任务与使用已完成任务的结果分离开来的服务。基于Executor的任务执行,与Future搭配使用。
对Executor框架的结构做了简单的描述之后,接下来就要进入源码解析的正篇部分了。这里笔者计划重点对框架中的ThreadPoolExecutor、FutureTask及一些工具类如Exchanger、CountDownLatch、CyclicBarrier、Semaphore和几个常用的并发集合如ArrayBlockingQueue、ConcurrentLinkedQueue、ConcurrentHashMap、CopyOnWriteArrayList做分析。
一个人的理解难免有片面和遗漏,还望各位海涵和指正。
相关文章推荐
- 转:javaweb开发超时设置
- Java注解Annotation详解
- java.lang.reflect.MalformedParameterizedTypeException
- logback + slf4j + jboss + spring mvc
- jar包冲突 java.lang.NoSuchMethodError: antlr.collecti
- SpringFramework4系列之SpringJMS:(一)搭建JMS-注解加XML版
- java -D参数简化加入多个jar【简化设置classpath】
- 2015070508 - EffactiveJava笔记 - 第13条 使类和成员的可访问性最小(2)
- JAVA基础-程序的基本结构、函数与数组
- 如何在java中使用sikuli进行自动化测试
- JAVA基础-面向对象之封装
- Java程序日志三
- 基于SSH验证框架的validation.xml验证不执行
- Eclipse提示No java virtual machine(转载)
- Spring的核心机制依赖注入简介
- JAVA 面向对象第四天
- Spring事务配置的五种方式
- java多线程01
- (原)编写JAVA工具之json自动封装成pojo
- Java程序日志四