java_bio

java_bio.java

var handler = (Consumer<byte[]>) (bytes) -> {
    CompletableFuture.runAsync(() -> {
        var readStr = new String(bytes);
        System.out.println("readStr: " + readStr);
    });
};

var inputStream = System.in;
var readThread = new Thread(() -> {
    try {
        var DEFAULT_BUFFER_SIZE = 8192;
        var buffer = new byte[DEFAULT_BUFFER_SIZE];
        int read;
        while ((read = inputStream.read(buffer, 0, DEFAULT_BUFFER_SIZE)) >= 0) {
            var readBytes = new byte[read];
            System.arraycopy(buffer, 0, readBytes, 0, read);
            handler.accept(readBytes);
        }
    } catch (IOException ex) {
        throw new UncheckedIOException(ex);
    }
});
readThread.start();
readThread.join();