Java : InterruptibleChannel - API使用例
2023年07月18日
InterruptibleChannel (Java SE 20 & JDK 20) の使用例まとめです。
だいたいのメソッドを網羅済みです。
API仕様のおともにどうぞ。
概要
非同期のクローズや割込みが可能なチャネルです。
InterruptibleChannel インタフェースは、割り込みが可能な チャネル です。
割り込みが発生すると、待機中のチャネル操作は ClosedByInterruptException が発生して中断します。
try (final var executor = Executors.newSingleThreadExecutor()) {
final var future = executor.submit(() -> {
try (final var channel = ServerSocketChannel.open()) {
System.out.println("InterruptibleChannel : "
+ (channel instanceof InterruptibleChannel));
System.out.println("bind ...");
channel.bind(new InetSocketAddress("127.0.0.1", 8000));
System.out.println("bind OK!");
System.out.println("accept ...");
channel.accept();
System.out.println("accept OK!");
} catch (ClosedByInterruptException e) {
System.out.println("ClosedByInterruptException!");
} catch (IOException e) {
System.out.println("IOException!");
}
});
TimeUnit.SECONDS.sleep(2);
System.out.println("-- future.cancel --");
future.cancel(true);
}
// 結果
// ↓
//InterruptibleChannel : true
//bind ...
//bind OK!
//accept ...
//-- future.cancel --
//ClosedByInterruptException!
また、別スレッドからチャネルを close すると、待機中のチャネル操作は AsynchronousCloseException が発生して中断します。
try (final var executor = Executors.newSingleThreadExecutor()) {
try (final var channel = ServerSocketChannel.open()) {
executor.submit(() -> {
try {
System.out.println("bind ...");
channel.bind(new InetSocketAddress("127.0.0.1", 8000));
System.out.println("bind OK!");
System.out.println("accept ...");
channel.accept();
System.out.println("accept OK!");
} catch (AsynchronousCloseException e) {
System.out.println("AsynchronousCloseException!");
} catch (IOException e) {
System.out.println("IOException!");
}
});
TimeUnit.SECONDS.sleep(2);
System.out.println("-- channel.close --");
}
}
// 結果
// ↓
//bind ...
//bind OK!
//accept ...
//-- channel.close --
//AsynchronousCloseException!
メソッド
void close ()
現在のチャネルをクローズします。
可能であれば try-with-resources文 を使うことをおすすめします。
final var path = Path.of("R:", "java-work", "test.data");
System.out.println(path); // R:\java-work\test.data
InterruptibleChannel channel;
try (final var fc = FileChannel.open(path,
StandardOpenOption.CREATE, StandardOpenOption.WRITE)) {
channel = fc;
System.out.println(channel.isOpen()); // true
}
System.out.println(channel.isOpen()); // false
try-with-resources文を使わない例です。
final var path = Path.of("R:", "java-work", "test.data");
System.out.println(path); // R:\java-work\test.data
final InterruptibleChannel channel = FileChannel.open(path,
StandardOpenOption.CREATE, StandardOpenOption.WRITE);
try {
System.out.println(channel.isOpen()); // true
} finally {
channel.close();
}
System.out.println(channel.isOpen()); // false
Channelで宣言されたメソッド
isOpen
「Java API 使用例 : Channel」をご参照ください。