如何连续扫描输入到控制台?

How to continuously scan input into console?

我肩负着学习的重任Java。我的想法是创建一个只有文本控制台的简单游戏。 "AI"(计时器)会定期发送一个字符串,玩家必须写入正确的字符串作为响应,否则 s/he 会失去一条生命。

因此,我的第一个问题是:有没有简单的方法来结合定时器和扫描器?我需要它不断 "watch" 字符串的控制台行。

经过一段时间的搜索和尝试,我在生成或生成字符串时最困难的地方进行了搜索,我发现了以下代码,但它有一个问题:

if ((name =in.nextLine(2000)) ==null)

如果我将条件重写为,例如,与 !="a" 而不是 null 进行比较,代码将忽略该条件并始终写入 "Too slow!" 无论如何。如果它是 =="a" 它总是说你好,一个。我完全不明白为什么,它似乎忽略了逻辑。 所以第二个问题是,为什么它在不同的时候忽略逻辑?我该如何解决?

public class TimedScanner
{
    public TimedScanner(InputStream input)
    {
        in = new Scanner(input);
    }

    private Scanner in;
    private ExecutorService ex = Executors.newSingleThreadExecutor(new ThreadFactory()
    {
        @Override
        public Thread newThread(Runnable r)
        {
            Thread t = new Thread(r);
            t.setDaemon(true);
            return t;
        }
    });

    public static void main(String[] args) {
        TimedScanner in = new TimedScanner(System.in);
        int playerHealth = 5;
        System.out.print("Enter your name: ");
        try {
            while (playerHealth > 0) {
                String name = null;
                if ((name = in.nextLine(3000)) ==null) {
                    System.out.println(name);
                    System.out.println("Too slow!");
                    playerHealth--;
                } else {
                    System.out.println(name);
                    System.out.println("Hello, " + name);
                }
            }
        } catch (InterruptedException | ExecutionException e) {
            //TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    public String nextLine(int timeout) throws InterruptedException, ExecutionException
    {
        Future<String> result = ex.submit(new Worker());
        try
        {
            return result.get(timeout, TimeUnit.MILLISECONDS);
        }
        catch (TimeoutException e)
        {
            return null;
        }
    }

    private class Worker implements Callable<String>
    {
        @Override
        public String call() throws Exception
        {
            return in.nextLine();
        }
    }
}

这是关于它应该做什么的非常准系统的想法。在我计划放入一个随机选择的字符串的同时,它将与控制台输入和错误的输入进行比较 = playerHealth--;正确输入其他内容。

2)为什么不一样的时候忽略逻辑?我该如何解决?

您已声明:

If I rewrite the condition to, for example, compare to !="a" instead of null, the code just ignores the condition and always writes "Too slow!" no matter what.

在 Java 中,从不(或几乎从不)使用 == 或 != 比较两个字符串。 String 是一个 Object,所以使用 == 比较它们意味着按地址而不是按值比较它们。所以

if ((name = in.nextLine(3000)) != "a")

将始终(或几乎总是)return 为真,因为从 #nextLine 中 return 编辑的任何字符串,无论是 "a" 还是其他内容,都将分配在堆上与硬编码 "a" 字符串不同的地址。我之所以说 "almost" 是因为 Java 使用了字符串池的概念:当创建对文字的新引用时,它会检查字符串是否已存在于池中以便重用它。但是你永远不应该依赖 ==。相反,使用 Object.Equals().

关于 Java 字符串池 here 的更多讨论。

1) 有没有简单的方法结合定时器和扫描器?

好吧,控制台 UI 在读取用户输入时,它对多线程并不是很友好,但是可以做到...

你的代码有问题:每当玩家失去生命时,它必须按两次 Enter - 当它连续失去 2 条生命时,它必须按 Enter 3 次才能收到 [=38 的积极反馈=].这是因为您没有终止前面的线程/取消前面的任务。所以我建议使用以下代码:

private static Scanner in;

public String nextLine(int timeout) throws InterruptedException, ExecutionException
{
    //keep a reference to the current worker
    Worker worker = new Worker();
    Future<String> result = ex.submit(worker);
    try
    {
        return result.get(timeout, TimeUnit.MILLISECONDS);
    }
    catch (TimeoutException e)
    {
        //ask the worker thread to stop
        worker.interrupt();
        return null;
    }
}

private class Worker implements Callable<String>
{
    //you want the most up-to-date value of the flag, so 'volatile', though it's not really necessary
    private volatile boolean interrupt;

    @Override
    public String call() throws Exception
    {
        //check whether there's something in the buffer;
        while (System.in.available() == 0){
            Thread.sleep(20);
            //check for the interrupt flag
            if(interrupt){
                throw new InterruptedException();
            }
        }
        //once this method is called there's no friendly way back - that's why we checked for nr of available bytes previously
        return in.nextLine();
    }

    public void interrupt(){
        this.interrupt = true;
    }
}