不正确调用中断（）

Question

我创建了一个ExecutorService来管理所有单独的线程，每个线程都处理一个套接字连接。我在每个线程中重写了中断方法，以便在线程中断时关闭套接字，以防套接字当前处于不可中断的方法（如socketserver.accept（））。

如果我在应用程序关闭时手动调用线程上的中断，一切都会正常关闭。但是，如果我使用我的ExecutorService并运行Shutdown Now，它似乎根本没有调用重写的中断方法。

为什么它不调用我被覆盖的方法？

Answer 1

我也遇到了同样的问题，并使用线程池找到了解决方案。有关说明和简化代码，请参见下文。

1）创建了我自己的线程类，它重写了中断（），也调用了一个关闭（）方法，该方法是使用我创建的set方法和Closeable接口配置的。如果已配置，重写中断（）以调用关闭方法。

public class CloseableThread extends Thread {
    private Closeable mCloseable = null;

    public interface Closeable {
        void close();
    }

    // Constructors deleted

    public void interrupt() {
        super.interrupt();
        if (mCloseable != null) {
            mCloseable.close();
        }
    }

    public void setCloseable(Closeable closeable) {
        mCloseable = closeable;
    }
}

2）创建了我自己的池类，它扩展了线程池，该线程池具有可关闭线程的工厂，并在设置可关闭线程之前重写。

public class CloseableThreadPoolExecutor extends ThreadPoolExecutor {
    static class CloseableThreadFactory implements ThreadFactory {
        public Thread newThread(Runnable r) {
            return (Thread) new CloseableThread(r);
        }
    }

    // Constructors deleted

    @Override
    protected void beforeExecute(Thread t, Runnable r) {
        super.beforeExecute(t, r);

        if (t instanceof CloseableThread && r instanceof Closeable) {
            ((CloseableThread) t).setCloseable((Closeable) r);
        }
    }
}

3）确保任何使用套接字的任务都实现了Closeable，并且关闭（）方法会以某种方式导致套接字关闭。请确保以这种方式关闭时干净地处理将生成的套接字异常。