对不起,我必须打开一个新线程来描述这个问题.

今天早上我问this question,有一些回复,但我的问题仍未解决.

这次我将附加一些可运行的代码(简化但有相同的问题),以便您重现问题：

public class ThreadPoolTest {
    public static void main(String[] args) throws Exception {
        final ExecutorService taskExecutor = Executors.newFixedThreadPool(5);
        Future<Void> futures[] = new Future[5];
        for (int i = 0; i < futures.length; ++i)
            futures[i] = startTask(taskExecutor);

        for (int i = 0; i < futures.length; ++i)
            System.out.println("futures[i].cancel(true): " + futures[i].cancel(true));

        System.out.println("Cancel DONE.");
        taskExecutor.shutdown();
    }

    private static Future<Void> startTask(final ExecutorService taskExecutor) {
        Future<Void> f = taskExecutor.submit(new Callable<Void>() {
            public Void call() throws Exception {
                try {
                    downloadFile(new URI("https://*.com"));
                    while(true) {
                        System.out.println(Thread.currentThread().getName() + ": " + Thread.currentThread().isInterrupted());
                        if(Thread.currentThread().isInterrupted())
                            break;
                    }
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
                return null;
            } 
        });
        return f;
    }

    private static void downloadFile (final URI uri) throws Exception {
//        if(true) return;
        Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
        return;
    }
}

上面的代码很可能被困在一个无限循环中(你可能希望多次运行代码来见证我看到的内容),正如你在main方法中看到的那样,我称之为future [i] .cancel(true)for所有的任务,我不知道为什么会这样,这已经让我折磨了一天多.

对你的帮助表示感谢.

解决方法:

我玩过你的代码,并注意到在创建套接字之前线程的中断状态有时是真的,之后是假的.

我试过打断一个线程并调用Socket构造函数,然后线程总是保持中断状态.我也尝试删除线程池的关闭,问题继续发生.

然后我尝试使用5个不同的URI,而不是总是相同的URI.问题从未发生过.

所以我写了这个简单的程序,表明线程池不是罪魁祸首,但套接字是：

public static void main(String[] args) throws Exception {
    final URI uri = new URI("https://*.com");
    for (int i = 0; i < 5; i++) {
        Runnable r = new Runnable() {
            @Override
            public void run() {
                Thread.currentThread().interrupt();
                System.out.println(Thread.currentThread().isInterrupted());
                try {
                    Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
                }
                catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().isInterrupted());
            }
        };
        new Thread(r).start();
    }
}

实际上,当5个线程创建到同一主机和端口的套接字时,其中4个线程的中断状态被清除.

然后我尝试同步套接字创建(在一个锁上,但我猜你可能每个主机/端口使用一个锁)：

synchronized(lock) {
    try {
        Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
    }
    catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

和TADA ……问题消失了.我会在Oracle上打开一个错误来表示问题.