如何正确中断正在读取用户输入的 Java 线程？

Question

我有一个耗时的任务compute()，我想在用户输入“abort”时手动中止。

为此，我有一个 Runnable InputAbort 使用无限循环和一个 BufferedReader 来扫描用户输入。当用户决定不中止长时间的计算时，就会出现问题。在这种情况下，运行InputAbort 的线程不会被正确中断，从而阻止 JVM 完成（使线程成为守护进程确实可以工作，但我认为必须有一种方法可以正确结束线程）。

当用户输入“abort”中止计算时，问题不会发生。当我删除 Runnable 中的 s = br.readLine(); 行并且用户等待计算完成时，它也不会发生。

启动线程和计算：

ComputationObject co = new ComputationObject();

Runnable rInputAbort = new InputAbort(co);
Thread tInputAbort = new Thread(rInputAbort);

tInputAbort.start();
co.compute();
tInputAbort.interrupt();

可运行：

public class InputAbort implements Runnable {
    private ComputationObject co;

    public RunnableInputAbort(ComputationObject co) {
        this.co = co;
    }

    @Override
    public void run() {
        try {
            InputStreamReader isr = new InputStreamReader(System.in);
            BufferedReader br = new BufferedReader(isr);
            String s = "";

            while ( ! Thread.currentThread().isInterrupted() ) {
                s =  br.readLine();
                if ( s.equals("abort") ) {
                    co.abort();
                    Thread.currentThread().interrupt();
                }
            }

            br.close();
            isr.close();

        }  catch (Exception e) {
            e.printStackTrace();
        }
    }

}

Answer 1

您不能中断正在读取输入的线程。见How to stop a thread waiting in a blocking read operation in Java?。

如果你只想退出 JVM，你可以这样做：

System.exit(0)

Answer 2

在BufferedReader 上检查ready() 为我解决了这个问题：

while ( ! Thread.currentThread().isInterrupted() ) {
    if ( br.ready() ) {
        s =  br.readLine();
        if ( s.equals("abort") ) {
            cb.doAbort();
            Thread.currentThread().interrupt();
        }
    }
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}

更多信息在这里（即使我的问题真的与超时无关）：

Is it possible to read from a InputStream with a timeout?