java 异步读写_Java异步与AIO
异步编程提供了一个非阻塞的,事件驱动的编程模型。 这种编程模型利用系统中多核执行任务来提供并行,因此提高了应用的吞吐率。Java异步编程通常需要使用Future,FutureTask和Callable,其中Future代表未来的某个结果,一般是向线程池提交任务时返回。
Future
示例代码:
public class PromiseTest {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(3);
List> futureList = new ArrayList<>();
for (int i = 0; i < 3; i++) {
int finalI = i;
Future future = executor.submit(() -> {
System.out.println("task["+ finalI +"] started!");
Thread.sleep(1000*(3-finalI));// cost some time
System.out.println("task["+ finalI +"]finished!");
return "result["+ finalI +"]";
});
futureList.add(future);
}
for (Future future : futureList) {
System.out.println(future.get());
}
System.out.println("Main thread finished.");
executor.shutdown();
}
}
执行结果:
task[0] started!
task[2] started!
task[1] started!
task[2]finished!
task[1]finished!
task[0]finished!
result[0]
result[1]
result[2]
Main thread finished.
有两个问题值得注意:
向线程池提交的三个任务同时开始执行,但是在使用get取结果的时候发现必须等耗时最长的任务结束之后才可以得到执行结果。
get方法阻塞了主线程,在取异步任务执行结果期间主线程不可以做其他事情。
这和真正意义上的异步编程模型是违背的,异步编程不存在线程阻塞的情况,因此仅使用Future来完成异步编程是不科学的。
CompletionService
CompletionService提供了一种将生产新的异步任务与使用已完成任务的结果分离开来的服务。生产者 submit 执行的任务,使用者 take 已完成的任务,并按照完成这些任务的顺序处理它们的结果,使用者总是可以取到最先完成任务的结果。
public class PromiseTest {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(3);
CompletionService service = new ExecutorCompletionService(executor);
for (int i = 0; i < 3; i++) {
int finalI = i;
service.submit(() -> {
System.out.println("task["+ finalI +"] started!");
Thread.sleep(1000*(3-finalI));// cost some time
System.out.println("task["+ finalI +"]finished!");
return "result["+ finalI +"]";
});
}
for (int i = 0; i < 3; i++) {
System.out.println(service.take().get());
}
System.out.println("Main thread finished.");
executor.shutdown();
}
}
执行结果:
task[0] started!
task[2] started!
task[1] started!
task[2]finished!
result[2]
task[1]finished!
result[1]
task[0]finished!
result[0]
Main thread finished.
可见,最耗时的任务在执行时并不影响其他主线程取到已完成任务的结果。但主线程仍然被get方法阻塞。
CompletableFuture
在JDK8发布之前,许多追求性能的框架都自己造了一套异步的实现,例如guava的ListenableFuture和netty的FutureListener,一直到Java8,才有了真正的官方异步实现, CompletableFuture提供了异步操作的支持,使用方法与Js中的Promise类似。
关于CompletableFuture的详细说明,请参考这篇:Java 8:CompletableFuture终极指南
使用这个API改写一下代码:
public class PromiseTest {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(3);
for (int i = 0; i < 3; i++) {
int finalI = i;
CompletableFuture future = CompletableFuture.supplyAsync(() -> {
System.out.println("task["+finalI+"] started!");
try {
// time cost
Thread.sleep(1000*(3-finalI));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("task["+finalI+"] finished");
return "result["+finalI+"]";
}, executor);
future.thenAccept(System.out::println);
}
System.out.println("Main thread finished.");
executor.shutdown();
}
}
结果与预期完全一致,各异步任务独自执行,互相不阻塞。
task[0] started!
Main thread finished.
task[1] started!
task[2] started!
task[2] finished
result[2]
task[1] finished
result[1]
task[0] finished
result[0]
异步IO
从编程模型角度来讲,IO操作方式有BIO/NIO/AIO,BIO就是传统的阻塞IO模型,关于NIO的介绍,也请参考这篇: Java NIO基础
与NIO区别的是,API提供的读写方法均是异步的,即对流或通道内容进行读写时并不会阻塞调用的主线程,JDK7在java.nio.channels包新增了以下4个API来支持异步IO:
AsynchronousSocketChannel
AsynchronousServerSocketChannel
AsynchronousFileChannel
AsynchronousDatagramChannel
AIO并没有加速IO处理速度,只是利用回调和通知机制改变了业务处理时机,使得具体逻辑可以不关注IO结果,只需在合理的时机添加回调即可。
例如:
public class AsyncServer {
public static void main(String[] args) {
try {
AsynchronousServerSocketChannel server = AsynchronousServerSocketChannel.open().bind(new InetSocketAddress(8000));
server.accept(null, new CompletionHandler() {
final ByteBuffer buffer = ByteBuffer.allocate(1024);
@Override
public void completed(AsynchronousSocketChannel result, Object attachment) {
Future writeResult = null;
try {
buffer.clear();
result.read(buffer).get(100, TimeUnit.SECONDS);
buffer.flip();
writeResult = result.write(buffer);
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
server.accept(null, this);
writeResult.get();
result.close();
} catch (Exception e) {
System.out.println(e.toString());
}
}
}
@Override
public void failed(Throwable exc, Object attachment) {
}
});
} catch (IOException e) {
e.printStackTrace();
}
}
}
通过CompletionHandler来添加一些回调,这样可以很方便地进行异步IO操作。
java 异步读写_Java异步与AIO相关推荐
- java 多异步调用_java 异步调用与多线程
异步与多线程的区别 一.异步和多线程有什么区别?其实,异步是目的,而多 线程是实现这个目的的方法.异步是说,A发起一个操作后(一般都是比较耗时的操作,如果不耗时的操作 就没有必要异步了),可以继续自顾 ...
- java filter 回调_Java 异步回调机制实例分析
Java 异步回调机制 一.什么是回调 回调,回调.要先有调用,才有调用者和被调用者之间的回调.所以在百度百科中是这样的: 软件模块之间总是存在着一定的接口,从调用方式上,可以把他们分为三类:同步调用 ...
- java 硬件中断_Java异步事件:轮询与中断
CPU几乎把所有的时间都花费在从内存获取指令并运行它们的过程中.然而,CPU和主存仅仅只是计算机硬件系统中众多组件的其中两个. 一个完整的系统还包含其他的设备,比如: 硬盘或者固态硬盘,用来存储程序和 ...
- java 异步通知_Java 异步回调机制实例解析
什么是回调?今天傻傻地截了张图问了下,然后被陈大牛回答道"就一个回调-".此时千万个草泥马飞奔而过 哈哈,看着源码,享受着这种回调在代码上的作用,真是美哉.不妨总结总结. 一.什么 ...
- java 异步记录日志_java异步写日志到文件中实现代码
java异步写日志到文件中详解 实现代码: package com.tydic.ESUtil; import java.io.File; import java.io.FileWriter; impo ...
- java异步线程_java异步线程
使用一个ExecutorService,增加两个不可取消的子线程任务,并且获取他们的返回值. @org.junit.Test public void testFuture() throws Int ...
- java xlsx读写_Java读写Excel
Java读写Excel 工作中经常需要对Excel进行读写操作,java操作excel文件比较流行的是apache poi包,excel分为xls(2003)和xlsx(2007)两种格式,操作这两种 ...
- java 对象读写_java 对象输入输出流读写文件的操作实例
java 对象输入输出流读写文件的操作实例 java 支持对对象的读写操作,所操作的对象必须实现Serializable接口. 实例代码: package vo; import java.io.Ser ...
- java流读写_java流概述以及文件读写示例
1. 先分清楚是字节流还是字符流. 字节流:InputStream OutputStream 字符流:Reader Writer 字符流与字节流的区别是读取的单位长度不同,字节流读8字节,字符流读16 ...
最新文章
- bios设置_老富士通bios设置启动项方法是什么 富士通bios设置u盘启动的方法
- SpringBoot maven打包源码发布到仓库配置
- .desktop 桌面快捷_Ubuntu 桌面手动添加应用快捷方式
- linux 下基本指令
- 个性化音乐推荐系统 协同过滤推荐算法在在线音乐播放系统中的应用 基于用户/项目的协同过滤推荐算法 混合协同过滤推荐算法 协同过滤混合推荐算法 代码实现开发 程序实现开发
- 【空号检测】批量手机号码空号检测查询软件,号码如何去除查询空号
- Java多线程 | 用多个线程模拟实现银行叫号系统
- 绘制谢尔宾斯基三角形
- tengxunyun init容器安装skywalking 挺NB的
- Python3脚本抢票
- vue3.0 使用vue脚手架生成vue项目 运行mapbox 3D地图例子
- 蒙特卡罗算法 与 拉斯维加斯算法
- 计算机网络知识面试常考
- HCIE课程笔记18-局域网二层技术
- SQL 如何去掉字段中千位的逗号(比如set @= '1,320.00' 想得到@= '1320.00' )
- 立冬养生,残秋尽,冬未隆,正是养藏时
- Win10链接XP共享文件夹
- android10 psp模拟器,ppsspp模拟器安卓版
- linux中wine文件夹在哪,科学网—Linux下wine的安装和使用以及CAJviewer的安装 - 苗玉虎的博文...
- 西安电子科技大学计算机学院 段毅,计算机网络与信息安全国家级实验教学示范中心举办“金山云AIoT教学模型培训交流活动”...
热门文章
- ABP从入门到精通(2):aspnet-zero-core 使用MySql数据库
- asp.net core AuthenticationMiddleware 在WebApi中的的使用
- 程序配置amp;amp;ConfigurationManager
- CoreCLR源码探索(五) GC内存收集器的内部实现 调试篇
- C#窗体的Load事件与Shown事件的区别
- ENVI帮助研究人员发现金矿
- Android之elevation实现阴影效果
- React Native之hardwareBackPress
- 浅谈C++类(5)--友元
- 链表之单链表的反转总结