如何中断被某些套接字 IO 操作阻塞的线程而不关闭它

Question

我真的很想知道如何中断被某些 I/O 操作阻塞的线程？ I/O 是通过套接字，我不想close() 套接字。

我尝试使用Thread.interrupt() 中断线程，但没有成功。

线程被 IO 操作阻塞：

void run(){
    byte[] data=new byte[1024];
    in.read(data);//blocked!
}

线程中断被阻塞的线程（没用）：

void run(){
    blockedThread.interrupt();//no success!
}

Answer 1

在获取SocketTimeoutException 时，在套接字上设置一个较短的读取超时并循环，每次都检查Thread.isInterrupted()。使用Thread.interrupt()中断线程。

Answer 2

I/O 之类的等待任何监视器的操作是不可中断的，这就是这些情况不需要 InterruptedException rutine 的原因，但根据 Java 7 Documentation 属于 @ 的 I/O 类987654326@ 包可以响应任何被中断的尝试，抛出流中断异常之一，其中之一是ClosedByInterruptionException 及其父类AsynchronousCloseException。

但如果您想关闭执行头，而不是关闭流，您可以考虑使用提供取消方式的FutureTask。

Answer 3

看看this blog post，尤其是解决方案 4 – 带缓冲的 NIO。

简而言之：对于常规文件，您必须使用NIO，使用扩展AbstractInterruptableChannel 的Channel，例如。 FileChannel.

当使用 sockets 时，使用Socket#close() 来中断/关闭。

根据 javadocs：

当前在此套接字上的 I/O 操作中阻塞的任何线程都将 抛出一个 SocketException。

但是：

解决这个问题还有另一种方法：使用NIO 的异步IO，看看here。 异步 IO 的问题在于，处理起来非常复杂（与阻塞 IO 相比），因为您将不再中继流，而是使用缓冲区。

Answer 4

如果您绝对不能/不想使用普通的 java Socket 类关闭套接字，您可以使用 java.nio.SocketChannel 来处理套接字。

SocketChannel 实现了InterruptibleChannel，可以通过中断在套接字上等待 I/O 的线程来关闭它。在这种情况下，被阻塞的读取会抛出一个ClosedByInterruptException

Answer 5

您可以添加这样的方法，因为任何阻塞 IO 操作都会抛出 IOException：-

public void close() throws IOException {
    this.socket.close();
}

来自 javadoc：-

关闭此套接字。当前在 accept() 中阻塞的任何线程都将 抛出一个 SocketException。

Answer 6

注意没有InterruptedException 声明被抛出：

阅读

public int read(byte[] b)
         throws IOException

从输入流中读取一些字节并将它们存储到缓冲区数组 b 中。实际读取的字节数以整数形式返回。在输入数据可用、检测到文件结尾或引发异常之前，此方法会一直阻塞。

一些读取方法会通过Thread#interrupt()响应外部中断，要么关闭流，要么抛出异常。

您不能否则停止该线程，除非以某种方式关闭或从另一个线程提供流，或者使用Thread#stop() 终止线程。最后一种方法只是最后的手段，不应出于各种原因使用。

Answer 7

不幸的是，大多数平台上的 sun java impl 不通过线程中断处理 io 中断（我相信你可以通过一些 nio 的东西来解决这个问题，不确定）。但是，我相信如果线程被阻塞从套接字读取，并且您有该套接字的句柄，您可以从另一个线程异步关闭套接字（这将中断被阻塞的线程）。