java executor 例子_Java中Executor框架的实例
这篇文章主要介绍了Java Executor 框架的实例详解的相关资料,这里提供实例来帮助大家学习理解这部分内容,需要的朋友可以参考下
Java Executor 框架的实例详解
大多数并发都是通过任务执行的方式来实现的。
一般有两种方式执行任务:串行和并行。
class SingleThreadWebServer {
public static void main(String[] args) throws Exception {
ServerSocket socket = new ServerSocket(80);
while(true) {
Socket conn = socket.accept();
handleRequest(conn);
}
}
}
class ThreadPerTaskWebServer {
public static void main(String[] args) throws Exception {
ServerSocket socket = new ServerSocket(80);
while(true) {
final Socket conn = socket.accept();
Runnable task = new Runnable() {
public void run() {
handleRequest(conn);
}
};
new Thread(task).start();
}
}
}
当然上面的这两种方式都是有问题的。单线程的问题就是并发量会是瓶颈,多线程版本就是无限制的创建线程会导致资源不足问题。
Executor 框架
任务是一组逻辑工作单元,而线程是使任务异步执行的机制。
JDK 提供了 Executor 接口:
public interface Executor {
void execute(Runnable command);
}
虽然 Executor 接口比较简单,但是却是异步任务执行框架的基础,该框架能支持多种不同类型的任务执行策略。它提供了一种标准的方式把任务的提交过程与执行过程进行了解耦。用 Runnable 来代表任务。Executor 的实现提供了对生命周期的支持以及统计信息应用程序管理等机制。
Executor 是基于生产者消费者模式的,提交任务的操作相当于生产者,执行任务的线程相当于消费。
基于 Executor 的 WebServer 例子如下:
public class TaskExecutorWebServer {
private static final int NTHREADS = 100;
private static final Executor exec = Executors.newFixedThreadPool(NTHREADS);
public static void main(String[] args) throws Exception {
ServerSocket serverSocket = new ServerSocket(80);
while (true) {
final Socket conn = serverSocket.accept();
Runnable task = new Runnable() {
@Override
public void run() {
handleRequest(conn);
}
};
exec.execute(task);
}
}
}
另外可以自己实现 Executor 来控制是并发还是并行的,如下面代码:
/**
* 执行已提交的 Runnable 任务的对象。
* 此接口提供一种将任务提交与每个任务将如何运行的机制(包括线程使用的细节、调度等)分离开来的方法。
* 通常使用 Executor 而不是显式地创建线程。
*
*
* @author renchunxiao
*
*/
public class ExecutorDemo {
public static void main(String[] args) {
Executor executor = new ThreadExecutor();
executor.execute(new Runnable() {
@Override
public void run() {
// do something
}
});
Executor executor2 = new SerialExecutor();
executor2.execute(new Runnable() {
@Override
public void run() {
// do something
}
});
}
}
/**
* 创建一个线程来执行 command
*
* @author renchunxiao
*
*/
class ThreadExecutor implements Executor {
@Override
public void execute(Runnable command) {
new Thread(command).start();
}
}
/**
* 串行执行 command
*
* @author renchunxiao
*
*/
class SerialExecutor implements Executor {
@Override
public void execute(Runnable command) {
command.run();
}
}
线程池
线程池就是线程的资源池,可以通过 Executors 中的静态工厂方法来创建线程池。newFixedThreadPool。创建固定长度的线程池,每次提交任务创建一个线程,直到达到线程池的最大数量,线程池的大小不再变化。
newSingleThreadExecutor。单个线程池。
newCachedThreadPool。根据任务规模变动的线程池。
newScheduledThreadPool。创建固定长度的线程池,以延迟或定时的方式来执行任务。
JVM 只有在所有非守护线程全部终止后才会退出,所以,如果无法正确的关闭 Executor,那么 JVM 就无法结束。
为了解决执行服务的生命周期问题,有个扩展 Executor 接口的新接口 ExecutorService。
public interface ExecutorService extends Executor {
void shutdown();
List shutdownNow();
boolean isShutdown();
boolean isTerminated();
boolean awaitTermination(long timeout, TimeUnit unit)
throws InterruptedException;
Future submit(Callable task);
Future submit(Runnable task, T result);
Future> submit(Runnable task);
List> invokeAll(Collection extends Callable> tasks)
throws InterruptedException;
List> invokeAll(Collection extends Callable> tasks,
long timeout, TimeUnit unit)
throws InterruptedException;
T invokeAny(Collection extends Callable> tasks)
throws InterruptedException, ExecutionException;
T invokeAny(Collection extends Callable> tasks,
long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;
}
ExecutorService 生命周期有三种状态:运行、关闭、已终止。ExecutorService 在初始创建时处于运行状态。shutdown 方法会平缓关闭:不在接受新的任务,并且等待已经执行的任务执行完成(包括那些还未开始的任务)。shutdownNow 方法将粗暴关闭:它将尝试取消所有运行中的任务,并且不再启动队列中尚未开始的任务。所有任务都执行完成后进入到已终止状态。
Callable 和 Future
Executor 框架使用 Runnable 作为基本的任务表示形式。Runnable 是一种有局限性的抽象,它的 run 方法不能返回值和抛出一个受检查异常。
许多任务实际上是存在延时的计算,例如数据库查询,从网络获取资源。对于这些任务,Callable 是更好的抽象,它认为 call 将返回一个值,并且可能抛出异常。
Executor 执行的任务有四个生命周期阶段:创建、提交、开始和完成。由于有些任务需要很长时间有可能希望取消,在 Executor 框架当中,已提交未开始的任务可以取消。
Future 表示一个任务的生命周期,并且提供了相应的方法来判断是否已经完成或取消,以及获取任务的结果和取消任务等。
java executor 例子_Java中Executor框架的实例相关推荐
- java 静态 编译_Java中的动态和静态编译实例详解
Java中的动态和静态编译实例详解 首先,我们来说说动态和静态编译的问题. Q: java和javascript有什么区别? 总结了一下:有以下几点吧: 1.首先从运行环境来说java代码是在JVM上 ...
- java synchronized 使用_Java中synchronized的使用实例
Java中synchronized的使用实例 synchronized关键字,代表这个方法加锁,相当于不管哪一个线程(例如线程A),运行到这个方法时,都要检查有没有其它线程B(或者C.D等)正在用这个 ...
- java gc 例子_Java 中, 为什么一个对象的实例方法在执行完成之前其对象可以被 GC 回收?...
收到好多邀请-泻药泻药.其中有好些感觉是想来吃瓜的. 所以请让我先跑个题,为吃瓜群众献上几个传送门: private static void newSingleThreadPool() { Execu ...
- java 泛型例子_java中的泛型的一些常见例子
/** * @author Rollen-Holt 使用泛型 */ class hello { hello(){ } public T getName(){ return name; } public ...
- java.equal例子_Java中的== 和equals()方法详解与实例
Java中的== 和equals()方法: Java中的数据类型,可分为两类: 1.基本数据类型,也称原始数据类型. byte,short,char,int,long,float,double,boo ...
- java实现备忘录_JAVA中的备忘录模式实例教程
原文链接 作者:Pankaj Kumar 译者:f0tlo <1357654289@qq.com> 备忘录模式是一种行为模式.备忘录模式用于保存对象当前状态,并且在之后可以再次使用此状态 ...
- java boolean例子_java.lang.Boolean.booleanValue()方法实例
全屏 java.lang.Boolean.booleanValue()返回该Boolean对象作为一个布尔原始值. 声明 以下是java.lang.Boolean.booleanValue()方法的声 ...
- 银行java多线程例子_Java 多线程 之 银行ATM实例
package com.thread; import java.util.Scanner; public class TestBank { public static void main(String ...
- java 注解开发_Java中的注解到底是如何工作的?
作者:人晓 www.importnew.com/10294.html 自Java5.0版本引入注解之后,它就成为了Java平台中非常重要的一部分.开发过程中,我们也时常在应用代码中会看到诸如@Over ...
- java 获取发布后的路径问题_Java中的路径问题实例分析
Java中的路径问题实例分析 前言:关于Java中得路径问题,网上有很多获取的答案,我这篇文章的目的在于说明获取路径时一些不常见的概念.在实际应用中使用的比较多的就是,当前路径和配置文件的路径(其他文 ...
最新文章
- 检测含有中文字符串的实际长度
- python免费视频-Python免费视频教程
- Windows应用程序类型和相应的入口点函数
- Matlab的File菜单功能图解 - 导入数据、保存工作空间、搜索路径、系统参数
- 批量提取文件创建时间_批量采集新浪微博用户内容
- linux date输出到文件,Linux常用命令--ls、cd、date用法
- c语言 在歌星大奖赛,C语言 歌星大奖赛为参赛的选手打分
- Vue CLI3 基本使用配置;
- 真不好意思,关于小猪妹(妖精)的
- 【渝粤教育】国家开放大学2018年春季 0176-21T电机学(一) 参考试题
- 程序员计算器HEX、EDC、OCT的意思
- SpringBoot 微信H5支付
- SatSun CRMS V2010 整站系统
- Android NFC M1卡读写芯片卡读写(CPU卡读写)(RFID读写)
- 2021年12月22日 腾讯会议Ipad录屏无法录制声音问题解决
- 重装系统找不到固态_SSD固态硬盘才装上确找不到盘怎么办 --好文
- BPR: Bayesian Personalized Ranking from Implicit Feedback 论文笔记
- vivo怎么切换为Android,vivox60怎么切换系统
- 获取分时数据,日k数据(A股,港股,美股)
- very very good,Java面试宝典+Java核心知识集