循环内输入的时间限制

Question

我想实现一个用户需要在固定时间限制内输入的功能。我已经完成了这个答案。

Time limit for an input

此示例一次有效。当用户没有给出固定输入时，程序正在终止。但我试图在一个循环中多次使用它。每次我都需要检查用户提供的输入。请参阅我的 InputTimer 类，根据该帖子答案修改。

InputTimer.java

public class InputTimer {
    private String str = "";
    public String responseString = "";
    private BufferedReader in;
    TimerTask task = new TimerTask() {
        public void run() {
            if (str.equals("")) {
                responseString = "";
            }
        }
    };

    public void getInput() throws Exception {
        Timer timer = new Timer();
        timer.schedule(task, 5 * 1000);

        in = new BufferedReader(new InputStreamReader(System.in));
        str = in.readLine();
        timer.cancel();
        responseString = str;
    }
}

我已尝试在循环内将其实现到另一个类：

for(int i=0; i<5; i++){
    System.out.println("Enter res in 5 sec: ");
    InputTimer inputTimer = new InputTimer();
    try {
        inputTimer.getInput();
    } catch (Exception e) {
        e.printStackTrace();
    }
    String responseString = inputTimer.responseString;
    if(responseString.equals("res")){
        //User typed res
    } else {
        //
    }
}

问题：按照我的逻辑，如果用户在5秒内输入res，那么responseString的值就是res，否则就是空值。这里 5 秒后仍在等待用户输入。

我的要求：如果用户在 5 秒内输入 res，那么它将适用于 //User typed res 任务并进行下一次迭代。如果用户在 5 秒内没有输入任何内容，用户将无法输入（用户输入选项将消失），responseString 值将变为空，否则将执行块，然后再次进行下一次迭代。

请帮我找出这个场景的解决方案。

这是 Joe C 解决方案的另一个尝试。它工作了一次。检查代码：

public class test {
    private static BlockingQueue<String> lines = new LinkedBlockingQueue<>();
    public static String inputTimer() throws InterruptedException {

        return lines.poll(5, TimeUnit.SECONDS);
    }

    public static void main(String[] args) {
        for (int i = 0; i < 5; i++) {
            String tmp = "";
            try {
                System.out.print("Iteration " + i + ": Enter any in 5 sec: ");
                Thread t = new Thread(() -> {
                Scanner s = new Scanner(System.in);
                while (true) {
                    lines.add(s.nextLine());
                }
            });
            t.setDaemon(true); 
            t.start();
                tmp = inputTimer();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("You entered: " + tmp);
        }
    }
}

输出日志：

Iteration 0: Enter any in 5 sec: xx
You entered: xx
Iteration 1: Enter any in 5 sec: xx
You entered: null
Iteration 2: Enter any in 5 sec: xx
You entered: null
Iteration 3: Enter any in 5 sec: xx
You entered: xx
Iteration 4: Enter any in 5 sec: You entered: xx

Answer 1

这可以通过基于事件的模型来实现。为此，您需要两个线程（其中一个可以是主线程）。

第一个线程将接受来自 Scanner 的输入并将其添加到事件队列中（在我们的例子中，“事件”只是输入的字符串）：

private BlockingQueue<String> lines = new LinkedBlockingQueue<>();

在您的主方法中启动所述线程：

Thread t = new Thread(() -> {
    Scanner s = new Scanner(System.in);
    while (true) {
        lines.add(s.nextLine());
    }
});
t.setDaemon(true); // so that this thread doesn't hang at the end of your program
t.start();

然后，当你想获取输入时，你可以通过超时从队列中获取：

return lines.poll(5, TimeUnit.SECONDS);