处理多线程读取输入

Question

我正在开发一个应用程序（控制台），其中包含一个while循环，我希望允许用户暂停和恢复。经过一些研究，似乎一个额外的线程负责等待用户输入是正确的解决方案。

我已经能够实现持续等待输入的额外线程，并且还有一个kill方法，它设置flag变量来停止线程while（）循环。不幸的是，除非有输入，否则while循环不会结束，只有在输入线程的while环至少完成一次后，这个kill标志才会生效。由于主线程也希望在自己的循环结束时输入，用户的输入被输入线程接受，导致主线程的Scanner错过输入，除非输入两次。有什么方法可以立即终止输入线程的while（）循环而不必完成一次迭代吗？是否需要某种超时功能？我已发布以下相关代码：

新线程的InputReader可运行代码:

public class ReadInput implements Runnable
{
    private static volatile boolean running = true;
    Scanner user_input = new Scanner(System.in);

    public void run()
    {
        while(running)
        {
            System.out.println("ReadingInput Input Value: " + user_input.nextLine());
        }
    }

    public void kill()
    {
        running = false;
        System.out.println("Thread Killed.");
    }
}

主线程代码：

//Start reader thread in order to scan for input without stopping main code
ReadInput reader = new ReadInput();
Thread reader_thread = new Thread(reader);
reader_thread.start();

while(code_available_for_processing)
{
    //Main Thread while() loop processing
}

//STOP Input Reader Thread before main thread requests input
reader.kill();

//Request user input for program re-run

Answer 1

使用Thread类的中断工具。这可能会导致被阻塞等待输入的线程抛出InterruptedIOException。有关更多信息，请参阅其他地方。