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操作。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/302802.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

你以为妹子穿短裙真的是为了诱惑你吗?

全世界有3.14 % 的人已经关注了数据与算法之美每年暑假&#xff0c;ChinaJoy 都会火热进行&#xff0c;无数一年不出家门的宅男们扛着“长枪大炮”&#xff0c;向着短裙姑娘们就冲过去了。关于裙子&#xff0c;林语堂曾有过一句名言&#xff1a;“演讲应该像女士的裙子&#xf…

聊一聊Jmeter的参数化

背景 前面一篇聊了一下 JMeter 的简单使用&#xff0c;这篇聊一下 JMeter 的参数化。在开始之前先来一个单元测试的例子&#xff0c;感受一下参数化。上面是一个用 xUnit 写的单元测试&#xff0c;这个单元测试就是一个参数化的例子&#xff1a;模拟了不同的输入&#xff0c;调…

Android VNC Server New

Android VNC Server New 关于VNC请参见维基百科&#xff1a;http://zh.wikipedia.org/wiki/VNC关于执行Android VNC Server&#xff0c;请参见前一篇文章&#xff1a;点击链接 一、VNC下载1&#xff09;fastdroid-vncAndroid VNC Server开源项目 http://code.google.com/p/fast…

python bind sock_python SOCKET编程详细介绍

本章内容1、socket2、IO多路复用3、socketserverSocketsocket起源于Unix&#xff0c;而Unix/Linux基本哲学之一就是“一切皆文件”&#xff0c;对于文件用【打开】【读写】【关闭】模式来操作。socket就是该模式的一个实现&#xff0c;socket即是一种特殊的文件&#xff0c;一些…

EPPlus导出Excel感觉很不错~~~

前言导出成为很多系统的必备功能&#xff0c;之前分享过导出PDF的功能&#xff0c;这里来分享一下Excel的导出&#xff1b;提到Excel导出&#xff0c;NPOI肯定是很多小伙伴的首选&#xff0c;在以往的项目中也用其完成了很多导出需求&#xff1b;对于NPOI&#xff0c;个人感觉使…

[文摘]标准的软件开发过程

为什么80%的码农都做不了架构师&#xff1f;>>> 软件开发的标准过程包括六个阶段&#xff0c;而六个阶段需要编写的各类文件达 14 种之多&#xff0c;在每个阶段需要编写哪些文件&#xff0c;以及这些文件的主要内容见下&#xff1a; 1.可行性与计划研究阶段 可行性…

python新闻评论分析_从新闻文章中提取评论

我的问题和这里问的问题类似&#xff1a;https://stackoverflow.com/questions/14599485/news-website-comment-analysis我试图从任何新闻文章中摘录评论。E、 g.我有一个新闻网址&#xff1a;http://www.cnn.com/2013/09/24/politics/un-obama-foreign-policy/我尝试在python中…

走进乔布斯的大脑

全世界有3.14 % 的人已经关注了数据与算法之美你永远也无法走进苹果教父乔布斯神秘的大脑&#xff0c;但下面的图可以让你多靠近了解他一点。人们都想走进乔帮主的大脑里看看他的想法&#xff0c;可惜他太难以捉摸了。但是&#xff0c;有个有趣的方法&#xff0c;至少可以让人们…

如何在没有 System.Drawing.Common 的情况下使用 C# 获取图片格式

之前写过一篇博文&#xff0c;用来获取图片的正确格式。博文所示代码一直工作良好&#xff0c;直到今天在将程序部署到阿里云函数计算时&#xff0c;发生了以下报错&#xff1a;System.Drawing is not supported on this platform.这表明我们不能在阿里云函数计算服务器上使用 …

Ant通配符

我们常用的匹配模式有ANT模式&#xff0c;比如acegi可以用PATTERN_TYPE_APACHE_ANT来使用ANT匹配模式&#xff0c;那什么是ANT匹配模式呢。ANT通配符有三种&#xff1a;通配符 说明 ? 匹配任何单字符 * 匹配0或者任意数量的字符 ** 匹配0或者更多的目录 例子&#xff1a;UR…

java二叉树的深度优先遍历_二叉树的广度优先遍历、深度优先遍历的递归和非递归实现方式...

1 packageSolution;23 importjava.util.LinkedList;4 importjava.util.Queue;5 importjava.util.Stack;678 public classBinaryTree {910 //二叉树节点11 public static classBinaryTreeNode {12 intvalue;13 BinaryTreeNode left;14 BinaryTreeNode right;1516 public BinaryT…

NET问答: 如何给 ASP.NET Core 配置指定端口 ?

咨询区 Drew Noakes&#xff1a;我是 ASP.NET Core 方面是新人&#xff0c;我发现程序默认的端口是 5000&#xff0c;因为要正式发布&#xff0c;所以希望把程序的端口改成 80&#xff0c;请问我该如何配置自定义端口呢 &#xff1f;回答区 Kvin Chalet&#xff1a;在 ASP.NET …

硬货 | 一片小小的薄膜,却可以粘住全世界!

延续“设计激发积极生活”的理念&#xff0c;在这个中秋&#xff0c;GYMLIVING特别推出月亮概念新产品&#xff0c;在便利生活的同时&#xff0c;为你带来一份浪漫和惊喜&#xff01;说起月亮&#xff0c;除了阴晴圆缺&#xff0c;月球漫步更让它成了浪漫的代名词。有公司正计划…

使用域超级管理员打开Exchange 2010发现没有权限

1.使用administrator管理员打开EMC却报没有权限。 2.发现此问题&#xff0c;系邮件服务器本身上安装了outlook软件&#xff0c;并配置了使用非administrator账户收信。并有做了Windows保存了用户凭据&#xff0c;造成帐号使用上的混乱&#xff0c;导致连接Exchange服务器时使用…

C# 将多个图片合并成TIFF文件的两种方法

最近需要用到TIF格式的文件&#xff0c;研究了一段时间&#xff0c;终于有点结果了&#xff0c;发现两种方式&#xff0c;第一种是使用BitMiracle.LibTiff.NET&#xff0c;直接在Nuget上安装即可&#xff0c;第二种是使用RasterEdge.DocImageSDK&#xff0c;要从官网下载dll包第…

高等数学、线性代数、概率论与数理统计、几何学这些知识可以用来干什么?主要应用有哪些?...

全世界有3.14 % 的人已经关注了数据与算法之美知乎谢漠烟其他三项&#xff0c;不研究少数工科确实没用&#xff0c;但概率统计真乃应用数学之王。鄙人学业从数学院开始&#xff0c;以经济学院结束&#xff0c;现在在证券公司做苦逼行业研究&#xff0c;深有体会。概率统计抛开了…

HDU 2896 病毒侵袭【AC自动机】

Problem Description当太阳的光辉逐渐被月亮遮蔽&#xff0c;世界失去了光明&#xff0c;大地迎来最黑暗的时刻。。。。在这样的时刻&#xff0c;人们却异常兴奋——我们能在有生之年看到500年一遇的世界奇观&#xff0c;那是多么幸福的事儿啊~~但网路上总有那么些网站&#xf…

.NET 中安全高效跨平台的模板引擎 Fluid 使用文档

Liquid 是一门开源的模板语言&#xff0c;由 Shopify 创造并用 Ruby 实现。它是 Shopify 主题的主要构成部分&#xff0c;并且被用于加载店铺系统的动态内容。它是一种安全的模板语言&#xff0c;对于非程序员的受众来说也非常容易理解。Fluid 是一个基于 Liquid 模板语言的开源…

风靡全球的人工智能,如何赶上这班车?

目前&#xff0c;机器学习的使用日渐成为趋势。作为人工智能的核心&#xff0c;机器学习是一门多领域的交叉学科&#xff0c;专门研究计算机模拟或实现人类学习行为的方法&#xff0c;以获取新的知识或技能&#xff0c;重新组织已有的知识结构使之不断改善自身的性能。简单来说…

java spark读写hdfs_Spark读取HDFS数据输出到不同的文件

最近有一个需求是这样的&#xff1a;原来的数据是存储在MySQL&#xff0c;然后通过Sqoop将MySQL的数据抽取到了HDFS集群上&#xff0c;抽取到HDFS上的数据都是纯数据&#xff0c;字段值之间以\t分隔&#xff0c;现在需要将这部分数据还原为json格式的&#xff0c;因为这样做的原…