Java Scanner输入超时处理：超时忽略输入且保持程序运行

Alright, let's figure out how to make this work—you want a Scanner input with a timeout that ignores the missing input instead of killing the whole program, right? Here's a solid, robust approach that solves this cleanly:

The core issue with your initial code is that the Scanner will keep blocking forever waiting for input even after the timeout, and the TimerTask doesn't handle cleaning up that blocked state. We need to:

1. Run the Scanner input in a separate thread so we can interrupt it on timeout
2. Cancel the timeout task if input is received in time
3. Clear the Scanner buffer post-timeout to avoid leftover input messing up future attempts

Full Working Code #

import java.util.Scanner;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class TimeoutInputHandler {
    private static final Scanner scanner = new Scanner(System.in);
    private static String userInput = "";
    private static volatile boolean inputReceived = false; // Volatile for thread safety

    public static void main(String[] args) {
        // Keep the program running to demonstrate continuous execution
        while (true) {
            resetInputState();
            
            // Set up scheduler for timeout task
            ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
            
            // Define what happens on timeout
            Runnable timeoutTask = () -> {
                if (!inputReceived) {
                    System.out.println("\nNo Valid Input detected - timeout reached");
                    // Clear any unread input from the buffer
                    while (scanner.hasNextLine()) {
                        scanner.nextLine();
                    }
                }
                scheduler.shutdown(); // Clean up the scheduler
            };
            // Schedule timeout to trigger after 5 seconds (adjust as needed)
            scheduler.schedule(timeoutTask, 5, TimeUnit.SECONDS);

            // Thread to handle user input
            Thread inputThread = new Thread(() -> {
                System.out.print("Enter input (5-second timeout): ");
                if (scanner.hasNextLine()) {
                    userInput = scanner.nextLine();
                    inputReceived = true;
                    scheduler.shutdownNow(); // Cancel timeout task since input arrived
                }
            });
            inputThread.start();

            // Wait for input thread or timeout to complete
            try {
                inputThread.join();
            } catch (InterruptedException e) {
                // Expected interruption when timeout triggers
                Thread.currentThread().interrupt();
            }

            // Process input if it was received
            if (inputReceived) {
                System.out.println("Success! Received input: " + userInput);
            }

            System.out.println("--- Program continues running ---");
        }
    }

    private static void resetInputState() {
        userInput = "";
        inputReceived = false;
    }
}

Key Details Explained #

• Separate Input Thread: The Scanner runs in its own thread so we don't block the main program. When the timeout hits, we don't need to kill the program—just let this thread exit gracefully.
• ScheduledExecutorService: Replaces Timer/TimerTask for better control over task cancellation. If input comes in before the timeout, shutdownNow() cancels the timeout task immediately.
• Buffer Clearing: The while (scanner.hasNextLine()) loop after timeout ensures any partial input the user started typing doesn't get picked up in the next iteration.
• Volatile Flag: inputReceived is marked volatile to ensure thread visibility—so the timeout task sees the updated value right when input is received.

This setup lets your program keep running indefinitely, prompting for input repeatedly with timeouts, and ignoring any missing input without crashing or halting.

内容的提问来源于stack exchange，提问作者Schera Haze