程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> Java 異步 IO

Java 異步 IO

編輯:關於JAVA

Java 異步 IO。本站提示廣大學習愛好者:(Java 異步 IO)文章只能為提供參考,不一定能成為您想要的結果。以下是Java 異步 IO正文


  新的異步功用的關鍵點,它們是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。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved