Java异步非阻塞模型AIO

所谓异步,即由一个线程读取文件,只需要告诉操作系统要读取文件,不用在此阻塞,继续向下执行其他代码,但读取完成后又由另一个线程通知读取完成

 主要借助AsynchronousFileChannel来实现

public class AIOFileChannel {
    public static void main(String[] args) throws IOException, InterruptedException {
        //第二个参数指明要进行的读或写操作
        AsynchronousFileChannel channel = AsynchronousFileChannel.open(Paths.get("abc.txt"),StandardOpenOption.READ);
        ByteBuffer buffer = ByteBuffer.allocate(16);
        //第三个参数为附件,一次读不完可以再读到附件里,第四个参数是读取成功或后的回调,由另一个线程来执行
        channel.read(buffer, 0, buffer, new CompletionHandler<Integer, ByteBuffer>() {
            @Override
            public void completed(Integer result, ByteBuffer attachment) {
                attachment.flip();
                while (attachment.hasRemaining()){
                    System.out.print((char)attachment.get());
                }
            }

            @Override
            public void failed(Throwable exc, ByteBuffer attachment) {
                exc.printStackTrace();
            }
        });
        //由于main为主线程,主线程结束其他线程立马结束,所以让主线程在此等候一下
        Thread.sleep(1000);
    }
}


版权声明:本文为a11157原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。