<强> Java执行人框架的实例详解
大多数并发都是通过任务执行的方式来实现的。
<强>一般有两种方式执行任务:串行和并行。
类SingleThreadWebServer {
公共静态void main (String [] args){抛出异常
ServerSocket插座=考察(80);
而(真){
套接字康涅狄格州=socket.accept ();
康涅狄格州handleRequest ();
}
}
}
类ThreadPerTaskWebServer {
公共静态void main (String [] args){抛出异常
ServerSocket插座=考察(80);
而(真){
最后一个套接字康涅狄格州=socket.accept ();
可运行任务=new Runnable () {
公共空间run () {
康涅狄格州handleRequest ();
}
}；
新线程(任务).start ();
}
}
}
之前
当然上面的这两种方式都是有问题的。单线程的问题就是并发量会是瓶颈,多线程版本就是无限制的创建线程会导致资源不足问题。
<强>执行人框架
任务是一组逻辑工作单元,而线程是使任务异步执行的机制。
JDK提供了执行人接口:
公共接口执行人{
无效执行(可运行命令);
}
之前
虽然执行人接口比较简单,但是却是异步任务执行框架的基础,该框架能支持多种不同类型的任务执行策略。它提供了一种标准的方式把任务的提交过程与执行过程进行了解耦。用Runnable来代表任务.Executor的实现提供了对生命周期的支持以及统计信息应用程序管理等机制。
执行人是基于生产者消费者模式的,提交任务的操作相当于生产者,执行任务的线程相当于消费。
基于遗嘱执行人的网络服务器例子如下:
公开课TaskExecutorWebServer {
私有静态最终int NTHREADS=100;
私有静态最终执行者执行=Executors.newFixedThreadPool (NTHREADS);
公共静态void main (String [] args){抛出异常
ServerSocket ServerSocket=考察(80);
而(真){
最后一个套接字康涅狄格州=serverSocket.accept ();
可运行任务=new Runnable () {
@Override
公共空间run () {
康涅狄格州handleRequest ();
}
}；
exec.execute(任务);
}
}
}
之前
另外可以自己实现执行人来控制是并发还是并行的,如下面代码:
/* *
*执行已提交的Runnable任务的对象。
*此接口提供一种将任务提交与每个任务将如何运行的机制(包括线程使用的细节,调度等)分离开来的方法。
*通常使用执行人而不是显式地创建线程。
*
*
* @author renchunxiao
*
*/公开课ExecutorDemo {
公共静态void main (String [] args) {
遗嘱执行人执行人=new ThreadExecutor ();
遗嘱执行人。执行(新Runnable () {
@Override
公共空间run () {//做某事
}
});
遗嘱执行人executor2=new SerialExecutor ();
executor2。执行(新Runnable () {
@Override
公共空间run () {//做某事
}
});
}
}/* *
*创建一个线程来执行命令
*
* @author renchunxiao
*
*/类ThreadExecutor实现遗嘱执行人{
@Override
公共空间执行(可运行命令){
新线程(命令).start ();
}
}/* *
*串行执行命令
*
* @author renchunxiao
*
*/类SerialExecutor实现遗嘱执行人{
@Override
公共空间执行(可运行命令){
command.run ();
}
}
之前
<强>线程池
线程池就是线程的资源池,可以通过执行人中的静态工厂方法来创建线程池。
<李> newFixedThreadPool。创建固定长度的线程池,每次提交任务创建一个线程,直到达到线程池的最大数量,线程池的大小不再变化。
<李> newSingleThreadExecutor。单个线程池。
<李> newCachedThreadPool。根据任务规模变动的线程池。
<李> newScheduledThreadPool。创建固定长度的线程池,以延迟或定时的方式来执行任务。
李
JVM只有在所有非守护线程全部终止后才会退出,所以,如果无法正确的关闭执行人,那么JVM就无法结束。
为了解决执行服务的生命周期问题,有个扩展执行人接口的新接口ExecutorService。
公共接口ExecutorService延伸执行人{
空间关闭();
List
