Blocking.java

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.URL;
import java.nio.channels.Channels;
import java.time.Instant;
import java.util.stream.Collectors;

public class Blocking {

	public static void main(String[] args) throws Exception {
		final Thread reader = new Thread() {
			@Override
			public void run() {
				log("Reader running...");
				try {
					String content = readBlockingIO(new URL("https://httpbin.org/delay/10"));
					// String content = readNIO(new URL("https://httpbin.org/delay/5"));
					log(content);
				} catch(Exception e) {
					log("Reading failed with " + e);
					e.printStackTrace();
				}
			}
		};
		reader.start();
		log("Reader started, waiting...");
		Thread.sleep(2000);
		new Thread() {
			@Override
			public void run() {
				log("Interrupting reader...");
				reader.interrupt();
			}
		}.start();
		reader.join();
		log("Done, exiting");
	}

	private static String readBlockingIO(URL url) throws IOException {
		InputStream in = url.openStream();
		log("Reading from input...");
		BufferedReader buffer = new BufferedReader(new InputStreamReader(in));
		return buffer.lines().collect(Collectors.joining("\n"));
	}

	private static String readNIO(URL url) throws IOException {
		InputStream in = url.openStream();
		log("Reading from input...");
		BufferedReader buffer = new BufferedReader(Channels.newReader(Channels.newChannel(in), "UTF-8"));
		return buffer.lines().collect(Collectors.joining("\n"));
	}

	private static void log(String msg) {
		System.out.println("[" + Instant.now() + "] " + msg);
	}

}