首页 技术 正文
技术 2022年11月6日
0 收藏 766 点赞 450 浏览 2079 个字

  新的异步功能的关键点,它们是Channel 类的一些子集,Channel 在处理IO操作的时候需要被切换成一个后台进程。一些需要访问较大,耗时的操作,或是其它的类似实例,可以考虑应用此功能。
在这里,我们只单独讲解针对文件IO操作的 AsynchronousFileChannel,但是需要注意的是,还有一些其他的异步管道。这里包括:

  • AsynchronousFileChannel:针对文件;
  • AsynchronousSocketChannel :针对客户端的socket;
  • AsynchronousServerSocketChannel:针对服务器端的异步socket,用来接收到来的连接。

针对异步管道的交互有两种不同的方式,

  1. Future 风格;
  2. callback 风格。

Future 风格的异步操作

这里需要使用Future 接口, 它可以被认为是一个正在进行的任务,也可能是尚未完成的任务。它有两个关键的方法:

isDone()
  返回一个布尔值来表示任务是否已经完成。
get()
  返回结果。如果任务完成,立即返回。否则,一直堵塞,直到完成。
让我们看段关于读取一个内容比较大的文件,或许超过100M的一个异步操作:

    try(AsynchronousFileChannel channel = AsynchronousFileChannel.open(Paths.get("input.txt"))) {
ByteBuffer buffer = ByteBuffer.allocateDirect(1024 * 1024 * 100);
Future<Integer> result = channel.read(buffer, 0); while(!result.isDone()) {
// do some other useful work
System.out.println("reading file, I can do other work.");
}
System.out.println("Bytes read: " + result.get());
} catch (IOException | InterruptedException | ExecutionException e) {
e.printStackTrace();
}

callback 风格的异步操作

  基于callback风格的异步操作需要 CompletionHandler的帮忙,它定义了两个方法, completed() 和failed(),分别用来表示在回调结束后是否完成和失败。
这种风格特别适用于,你想在异步IO操作中立即知道事件的通知。例如,如果在云中有大量的I O操作,但任何单一操作的失败不一定是致命的。看例子。

        byte[] data = { 2, 3, 5, 7, 11, 13, 17, 19, 23 };
ByteBuffer buffer = ByteBuffer.wrap(data); CompletionHandler<Integer, Object> handler = new CompletionHandler<Integer, Object>() {
@Override
public void completed(Integer result, Object attachment) { // success
System.out.println("Bytes written: " + result);
} @Override
public void failed(Throwable exc, Object attachment) { // failed
System.out.println("Asynch write failed: " + exc.getMessage());
}
}; try (AsynchronousFileChannel channel = AsynchronousFileChannel.open(Paths.get("primes.txt"),
StandardOpenOption.CREATE, StandardOpenOption.WRITE)) { channel.write(buffer, 0, null, handler); Thread.sleep(10000); // Needed so we don't exit too quickly
} catch (IOException | InterruptedException e) {
e.printStackTrace();
}

  AsynchronousFileChannel 与后台线程池相连接,所以当初始线程处理其他任务的时候,以至于IO操作能够得以进行。
默认情况下,这种情况实际是管理一个运行时环境提供了的线程池,如果有需要,可以通过应用程序(通过重载 AsynchronousFileChannel.open()方法)创建一个自定义的线程池,不过这种情况通常不是必要的。
  另外,在nio 中还支持多重IO,这样就可以使一个单线程管理多个IO管道和检查它的哪些IO管道是否做好了读取和写入的准备,支持此操作的一些类在 java.nio.channels包下,包括 SelectableChannel 和 Selector。

相关推荐
python开发_常用的python模块及安装方法
adodb:我们领导推荐的数据库连接组件bsddb3:BerkeleyDB的连接组件Cheetah-1.0:我比较喜欢这个版本的cheeta…
日期:2022-11-24 点赞:878 阅读:9,078
Educational Codeforces Round 11 C. Hard Process 二分
C. Hard Process题目连接:http://www.codeforces.com/contest/660/problem/CDes…
日期:2022-11-24 点赞:807 阅读:5,553
下载Ubuntn 17.04 内核源代码
zengkefu@server1:/usr/src$ uname -aLinux server1 4.10.0-19-generic #21…
日期:2022-11-24 点赞:569 阅读:6,402
可用Active Desktop Calendar V7.86 注册码序列号
可用Active Desktop Calendar V7.86 注册码序列号Name: www.greendown.cn Code: &nb…
日期:2022-11-24 点赞:733 阅读:6,177
Android调用系统相机、自定义相机、处理大图片
Android调用系统相机和自定义相机实例本博文主要是介绍了android上使用相机进行拍照并显示的两种方式,并且由于涉及到要把拍到的照片显…
日期:2022-11-24 点赞:512 阅读:7,814
Struts的使用
一、Struts2的获取  Struts的官方网站为:http://struts.apache.org/  下载完Struts2的jar包,…
日期:2022-11-24 点赞:671 阅读:4,898