[多线程]java不支持中断的多线程处理#多线程#中断

SocketIntterruptHandler.java

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
 
public class Test32 extends Thread {
    public static final int BUF_SIZE = 512;
 
    Socket socket;
    InputStream in;
 
    public Test32(Socket socket) throws IOException {
        this.socket = socket;
        this.in = socket.getInputStream();
    }
 
    @Override
    public void interrupt() {
        try {
            socket.close();
        } catch (IOException e) {
 
        } finally {
            super.interrupt();
        }
    }
 
    @Override
    public void run() {
        try {
            byte[] buf = new byte[BUF_SIZE];
            while (true) {
                int count = in.read(buf);
                if (count < 0) {
                    break;
                } else if (count > 0) {
 
                }
            }
        } catch (IOException e) {
 
        }
 
    }
 
}