Przerwanie wątku w DatagramSocket.receive

Question

Buduję aplikację, która nasłuchuje zarówno na TCP, jak i UDP, i mam problem z moim mechanizmem zamykania. Kiedy zadzwonię pod numer Thread.interrupt() na każdym z wątków nasłuchujących, wątek TCP zostanie przerwany ze słuchania, podczas gdy słuchacz UDP nie jest. Aby być konkretnym, wątek TCP używa ServerSocket.accept(), który po prostu zwraca (bez faktycznego łączenia). Podczas gdy wątek UDP używa DatagramSocket.receive() i nie wychodzi z tej metody.

Czy jest to problem występujący w moim środowisku JRE, systemie operacyjnym lub czy powinienem przejść na numer (Datagram)Socket.close()?

AKTUALIZACJA: Znalazłem analysis problemu. Potwierdza, że ​​zachowanie nie jest spójne.

Answer 1

Powszechnym idiomem dla przerywania pracy sieciowej jest zamknięcie kanału. Byłoby to dobre rozwiązanie, gdybyś musiał skutecznie je przerwać, czekając na wysłanie lub odebranie.

public class InterruptableUDPThread extends Thread{ 

    private final DatagramSocket socket; 

    public InterruptableUDPThread(DatagramSocket socket){ 
     this.socket = socket; 
    } 
    @Override 
    public void interrupt(){ 
    super.interrupt(); 
    this.socket.close(); 
    } 
} 

Answer 2

DatagramSocket.receive blokuje do momentu otrzymania datagramu. Prawdopodobnie musisz użyć setSoTimeout, aby ustawić limit czasu.

Answer 3

Z tego co wiem, close() jest właściwym sposobem przerwania zablokowanego gniazda. Przerwanie i pozostawienie otwartego czegoś, co mogło już zrobić częściowy odczyt lub zapis, sprawia, że ​​rzeczy stają się niepotrzebnie skomplikowane. Łatwiej jest tylko radzić sobie z wynikiem "sukcesu" lub "rezygnacji".