Interrupt/stop thread with socket I/O blocking operation

Question

At some point of my server application I want to stop some threads that are performing I/O blocking operations.

For instance, one of them have the following run() method:

public void run() {
    System.out.println("GWsocket thread running");

    int len;
    byte [] buffer = new byte[1500];
    try {
        this.in  = new DataInputStream(this.socket.getInputStream());
        this.out = new DataOutputStream(this.socket.getOutputStream());
        running = true;

        while (running){
            len = in.read (buffer);
            if (len < 0)
                running = false;
            else
                parsepacket (buffer, len);
        }

    }catch (IOException ex) {
        System.out.println("GWsocket catch IOException: "+ex);
    }finally{
        try {
            System.out.println("Closing GWsocket");
            fireSocketClosure();
            in.close();
            out.close();
            socket.close();
        }catch (IOException ex) {
            System.out.println("GWsocket finally IOException: "+ex);
        }
    }
}

If I Want to stop a thread running this code, what should I do?

Here they show how to do (How do I stop a thread that waits for long periods (e.g., for input)?), but I don't understand what they mean with:

For this technique to work, it's critical that any method that catches an interrupt exception and is not prepared to deal with it immediately reasserts the exception. We say reasserts rather than rethrows, because it is not always possible to rethrow the exception. If the method that catches the InterruptedException is not declared to throw this (checked) exception, then it should "reinterrupt itself" with the following incantation: Thread.currentThread().interrupt();

Can anyone give me some hints? Some code examples would be very appreciated.

score 6 · Answer 1 · answered Sep 07 '12 at 09:17

6

You can add a method like

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

and any blocking IO operations will throw a SocketException.

You might like to set a flag like closed which you can check if an exception thrown was to be expected or not.

BTW: You cannot be sure that you will get discrete packets on a read. It is far better to read what you need and use BufferedInputStream for efficiency. Only read blocks if you don't need to parse the contents e.g. copying from a socket to a file.

e.g. your read could get just one byte or get the end of one packet and the start of another.

answered Sep 07 '12 at 09:17

Peter Lawrey

525,659
79
751
1,130

Hi, thanks for your answer. Sometimes the `len = in.read (buffer);` gives me an IOException... Could be because I am using `DataInputStream` instead of `BufferedInputStream`? – amp Sep 07 '12 at 13:34
Which stream you wrap it with makes no difference. – Peter Lawrey Sep 07 '12 at 13:37

score 6 · Accepted Answer · edited May 23 '17 at 12:31

6

A solution, described by Peter Lawrey and also seen here is to close the socket.

With nio, You could also use a SocketChannel which is interruptible and would allow the application of the standard interrupt model of Java.

A call to the interrupt method of your Thread object would throw an InterruptedException which would stop even your blocking IO operation.

edited May 23 '17 at 12:31

Community

1
1

answered Sep 07 '12 at 09:30

Denys Séguret

372,613
87
782
758

Interrupt/stop thread with socket I/O blocking operation

2 Answers2

Linked