Làm thế nào để chấm dứt một thread chặn trên hoạt động IO socket ngay lập tức?

Question

Trong ngữ cảnh của Java, tôi tạo một luồng mới để đọc đầu vào mạng khi mở một cửa sổ GUI, và khi tôi đóng cửa sổ, tôi muốn giải phóng tài nguyên ổ cắm và chấm dứt chuỗi ngay lập tức. Bây giờ tôi đang sử dụng phương pháp setSoTimeout, nhưng tôi không muốn chờ đợi các ngoại lệ timeout. Ai có thể đưa ra một số gợi ý? Cảm ơn!

Answer 1

Có (khả năng) ba cách để làm điều này:

• Calling Socket.close() trên socket sẽ đóng liên InputStream và OutputStream đối tượng, và gây ra bất kỳ đề chặn Socket hoặc (liên quan) dòng hoạt động để được bỏ chặn. Theo javadoc, các hoạt động trên chính socket sẽ ném một SocketException.

• Gọi Thread.interrupt() sẽ (trong một số trường hợp không được chỉ định) sẽ làm gián đoạn hoạt động I/O chặn, khiến nó ném một số InterruptedIOException.

  ^{Lưu ý báo trước. Rõ ràng cách tiếp cận "ngắt()" không hoạt động trên các nền tảng Java "hiện đại nhất". (Nếu ai đó có thời gian và độ nghiêng, họ có thể điều tra các trường hợp mà phương pháp này hoạt động. Tuy nhiên, thực tế là hành vi là nền tảng cụ thể nên đủ để nói rằng bạn chỉ nên sử dụng nó nếu bạn chỉ cần ứng dụng của bạn để làm việc trên một nền tảng cụ thể. Tại thời điểm đó, bạn có thể dễ dàng "thử" cho chính mình.)}

• Cách thứ ba có thể thực hiện là gọi Socket.shutdownInput() và/hoặc Socket.shutdownOutput(). Các javadocs không nói rõ ràng những gì xảy ra với các hoạt động đọc và/hoặc ghi hiện đang bị chặn, nhưng nó không phải là không hợp lý khi nghĩ rằng chúng sẽ bỏ chặn và ném một ngoại lệ. Tuy nhiên, nếu javadoc không nói điều gì xảy ra thì hành vi đó sẽ được giả định là nền tảng cụ thể.

Answer 2

Tôi biết câu hỏi này là cũ nhưng không ai dường như đã giải quyết được "bí ẩn" của Thread.interrupt() trên "nền tảng hiện đại" tôi đã thực hiện một số nghiên cứu.

Điều này được kiểm tra trên Java 8 trên Windows7 (64-bit) (nhưng nó cũng có thể đúng đối với các nền tảng khác).

Calling Thread.interrupt() không không ném một InterruptedIOException gì xảy ra là phương pháp InputStream.read() trả về với -1 và Thread.interrupted() -flag được thiết lập.

Vì vậy, những điều sau đây có thể được coi là một 'điều chỉnh' read() ném InterruptedIOException:

static final int read(Socket socket, byte[] inData) 
    throws SocketTimeoutException, // if setSoTimeout() was set and read timed out 
      InterruptedIOException, // if thread interrupted 
      IOException    // other erors 
{ 
    InputStream in = socket.getInputStream(); 

    int readBytes = in.read(inData, 0, inData.length); 

    if (Thread.interrupted()) 
    { 
     throw new InterruptedIOException("Thread interrupted during socket read"); 
    } 

    return readBytes; 
}