Preface:<\/strong> Given your “console application” doesn’t involve forking any processes or performing any “actual” I\/O, you may want to redesign your application to use the Reading characters from standard in and writing characters to standard out will involve decoding and encoding those characters. You’ll want to use classes which already implement this for you, such as Also, since most console-based applications can print prompting text without a new line at the end, you have to “read from” standard out by reading each individual character rather than line-by-line. This could involve a lot of calls to The example below shows a proof-of-concept<\/em> for this. It uses UTF-8 for the character encoding. There’s a GIF of the example code running at the end of this answer.<\/p>\n Here’s a brief overview of the classes:<\/p>\n Note that I have the Main.java<\/strong><\/p>\n BufferedTextAreaAppender.java<\/strong><\/p>\n StreamReader.java<\/strong> (could probably use a better name)<\/p>\n StreamWriter.java<\/strong> (could probably use a better name)<\/p>\n ConsoleTask.java<\/strong><\/p>\nTextField<\/code> and TextArea<\/code> directly, or at least more directly than you’re currently trying to do. Using System.out<\/code> and System.in<\/code> adds a layer of unnecessary indirection and makes everything more complex. Also, redirecting standard out and standard in affects the whole process, which may not be desirable.<\/em><\/p>\n
\nGeneral Idea<\/h1>\n
BufferedReader<\/code> and BufferedWriter<\/code>. And since you essentially want to communicate between threads via streams, you can have the underlying streams be instances of PipedInputStream<\/code> and PipedOutputStream<\/code>.<\/p>\nPlatform#runLater(Runnable)<\/code>, potentially overwhelming the FX thread, which means you should probably buffer this output.<\/p>\n\n\n
\n \nClass<\/th>\n Description<\/th>\n<\/tr>\n<\/thead>\n \n Main<\/code><\/td>\nThe JavaFX application class. Creates the UI and otherwise initializes and starts the application.<\/td>\n<\/tr>\n \n StreamWriter<\/code><\/td>\nResponsible for writing the user’s input so that it can later be read by System.in<\/code>. Also provides the code for redirecting System.in<\/code> so that ultimately the input can come from a TextField<\/code>.<\/td>\n<\/tr>\n\n StreamReader<\/code><\/td>\nResponsible for reading the output from System.out<\/code> character-by-character. Also provides the code for redirecting System.out<\/code> so that ultimately it can be appended to a TextArea<\/code>.<\/td>\n<\/tr>\n\n BufferedTextAreaAppender<\/code><\/td>\nResponsible for taking the stream of characters from StreamReader<\/code> and appending them to the TextArea<\/code> in batches.<\/td>\n<\/tr>\n\n ConsoleTask<\/code><\/td>\nThe “console application”. Uses System.in<\/code> and System.out<\/code> to interact with the user.<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n
\nExample<\/h1>\n
TextArea<\/code> set up to automatically scroll to the end when the text changes. Unfortunately, this doesn’t seem to work the first time text goes “off the screen”. But after that first time it seems to work.<\/p>\nimport java.io.IOException;\nimport java.util.concurrent.ExecutorService;\nimport java.util.concurrent.Executors;\nimport javafx.application.Application;\nimport javafx.application.Platform;\nimport javafx.geometry.Insets;\nimport javafx.scene.Scene;\nimport javafx.scene.control.TextArea;\nimport javafx.scene.control.TextField;\nimport javafx.scene.layout.Priority;\nimport javafx.scene.layout.VBox;\nimport javafx.scene.text.Font;\nimport javafx.stage.Stage;\n\npublic class Main extends Application {\n\n private final ExecutorService threadPool = Executors.newFixedThreadPool(3, r -> {\n var t = new Thread(r);\n t.setDaemon(true);\n return t;\n });\n\n @Override\n public void start(Stage primaryStage) throws Exception {\n var textField = new TextField();\n textField.setFont(Font.font(\"Monospaced\", 13));\n\n var textArea = new TextArea();\n textArea.setFont(textField.getFont());\n textArea.setEditable(false);\n textArea.setFocusTraversable(false);\n textArea.textProperty().addListener(obs -> textArea.end());\n\n var root = new VBox(10, textArea, textField);\n root.setPadding(new Insets(10));\n VBox.setVgrow(textArea, Priority.ALWAYS);\n\n primaryStage.setScene(new Scene(root, 600, 400));\n textField.requestFocus();\n\n primaryStage.setTitle(\"Console App\");\n primaryStage.show();\n\n wireInputAndOutput(textField, textArea);\n startConsoleTask();\n }\n\n private void wireInputAndOutput(TextField input, TextArea output) throws IOException {\n var inputConsumer = StreamWriter.redirectStandardIn(threadPool);\n StreamReader.redirectStandardOut(new BufferedTextAreaAppender(output), threadPool);\n\n input.setOnAction(e -> {\n e.consume();\n var text = input.textProperty().getValueSafe() + \"\\n\";\n output.appendText(text);\n inputConsumer.accept(text);\n input.clear();\n });\n }\n\n private void startConsoleTask() {\n threadPool.execute(new ConsoleTask(Platform::exit));\n }\n\n @Override\n public void stop() {\n threadPool.shutdownNow();\n }\n}\n<\/code><\/pre>\nimport java.util.function.IntConsumer;\nimport javafx.application.Platform;\nimport javafx.scene.control.TextArea;\n\nclass BufferedTextAreaAppender implements IntConsumer {\n\n private final StringBuilder buffer = new StringBuilder();\n private final TextArea textArea;\n private boolean runLater = true;\n\n BufferedTextAreaAppender(TextArea textArea) {\n this.textArea = textArea;\n }\n\n @Override\n public void accept(int characterCodePoint) {\n synchronized (buffer) {\n buffer.append((char) characterCodePoint);\n if (runLater) {\n runLater = false;\n Platform.runLater(this::appendToTextArea);\n }\n }\n }\n\n private void appendToTextArea() {\n synchronized (buffer) {\n textArea.appendText(buffer.toString());\n buffer.delete(0, buffer.length());\n runLater = true;\n }\n }\n}\n<\/code><\/pre>\nimport java.io.BufferedReader;\nimport java.io.IOException;\nimport java.io.InputStream;\nimport java.io.InputStreamReader;\nimport java.io.InterruptedIOException;\nimport java.io.PipedInputStream;\nimport java.io.PipedOutputStream;\nimport java.io.PrintStream;\nimport java.io.UncheckedIOException;\nimport java.nio.charset.StandardCharsets;\nimport java.util.concurrent.Executor;\nimport java.util.function.IntConsumer;\n\nclass StreamReader implements Runnable {\n\n static void redirectStandardOut(IntConsumer onNextCharacter, Executor executor) throws IOException {\n var out = new PipedOutputStream();\n System.setOut(new PrintStream(out, true, StandardCharsets.UTF_8));\n\n var reader = new StreamReader(new PipedInputStream(out), onNextCharacter);\n executor.execute(reader);\n }\n\n private final BufferedReader reader;\n private final IntConsumer onNextCharacter;\n\n StreamReader(InputStream stream, IntConsumer onNextCharacter) {\n this.reader = new BufferedReader(new InputStreamReader(stream, StandardCharsets.UTF_8));\n this.onNextCharacter = onNextCharacter;\n }\n\n @Override\n public void run() {\n try (reader) {\n int charAsInt;\n while (!Thread.interrupted() && (charAsInt = reader.read()) != -1) {\n onNextCharacter.accept(charAsInt);\n }\n } catch (InterruptedIOException ignore) {\n } catch (IOException ioe) {\n throw new UncheckedIOException(ioe);\n }\n }\n}\n<\/code><\/pre>\nimport java.io.BufferedWriter;\nimport java.io.IOException;\nimport java.io.InterruptedIOException;\nimport java.io.OutputStream;\nimport java.io.OutputStreamWriter;\nimport java.io.PipedInputStream;\nimport java.io.PipedOutputStream;\nimport java.io.UncheckedIOException;\nimport java.nio.charset.StandardCharsets;\nimport java.util.concurrent.ArrayBlockingQueue;\nimport java.util.concurrent.BlockingQueue;\nimport java.util.concurrent.Executor;\nimport java.util.function.Consumer;\n\nclass StreamWriter implements Runnable {\n\n static Consumer<CharSequence> redirectStandardIn(Executor executor) throws IOException {\n var in = new PipedInputStream();\n System.setIn(in);\n\n var queue = new ArrayBlockingQueue<CharSequence>(500);\n var writer = new StreamWriter(new PipedOutputStream(in), queue);\n executor.execute(writer);\n\n return queue::add;\n }\n\n private final BufferedWriter writer;\n private final BlockingQueue<? extends CharSequence> lineQueue;\n\n StreamWriter(OutputStream out, BlockingQueue<? extends CharSequence> lineQueue) {\n this.writer = new BufferedWriter(new OutputStreamWriter(out, StandardCharsets.UTF_8));\n this.lineQueue = lineQueue;\n }\n\n @Override\n public void run() {\n try (writer) {\n while (!Thread.interrupted()) {\n writer.append(lineQueue.take());\n writer.flush();\n }\n } catch (InterruptedIOException | InterruptedException ignore) {\n } catch (IOException ioe) {\n throw new UncheckedIOException(ioe);\n }\n }\n}\n<\/code><\/pre>\nimport java.nio.charset.StandardCharsets;\nimport java.util.NoSuchElementException;\nimport java.util.Scanner;\n\nclass ConsoleTask implements Runnable {\n\n private final Scanner scanner = new Scanner(System.in);\n private final Runnable onExit;\n\n ConsoleTask(Runnable onExit) {\n this.onExit = onExit;\n }\n\n @Override\n public void run() {\n System.out.println(\"WELCOME TO CONSOLE APP!\");\n\n boolean running = true;\n while (running && !Thread.interrupted()) {\n printOptions();\n\n int choice = readInt(\"Choose option: \", 1, 3);\n switch (choice) {\n case 1 -> doCheckIfLeapYear();\n case 2 -> doCheckIfPrime();\n case 3 -> running = false;\n default -> System.out.println(\"Unknown option!\");\n }\n }\n\n onExit.run();\n }\n\n private void printOptions() {\n System.out.println();\n System.out.println(\"Options\");\n System.out.println(\"-------\");\n System.out.println(\" 1) Test Leap Year\");\n System.out.println(\" 2) Test Prime\");\n System.out.println(\" 3) Exit\");\n System.out.println();\n }\n\n private int readInt(String prompt, int min, int max) {\n while (true) {\n System.out.print(prompt);\n\n try {\n int i = Integer.parseInt(scanner.nextLine());\n if (i >= min && i <= max) {\n return i;\n }\n } catch (NumberFormatException | NoSuchElementException ignored) {\n }\n System.out.printf(\"Please enter an integer between [%,d, %,d]%n\", min, max);\n }\n }\n\n private void doCheckIfLeapYear() {\n System.out.println();\n int year = readInt(\"Enter year: \", 0, 1_000_000);\n if (year % 4 == 0 || (year % 100 == 0 && year % 400 != 0)) {\n System.out.printf(\"The year %d is a leap year.%n\", year);\n } else {\n System.out.printf(\"The year %d is NOT a leap year.%n\", year);\n }\n }\n\n private void doCheckIfPrime() {\n System.out.println();\n int number = readInt(\"Enter an integer: \", 1, Integer.MAX_VALUE);\n\n boolean isPrime = true;\n for (int i = 2; i <= (int) Math.sqrt(number); i++) {\n if (number % i == 0) {\n isPrime = false;\n break;\n }\n }\n\n if (isPrime) {\n System.out.printf(\"The number %,d is prime.%n\", number);\n } else {\n System.out.printf(\"The number %,d is NOT prime.%n\", number);\n }\n }\n}\n<\/code><\/pre>\nGIF of Example<\/h2>\n
![\"GIF](\"https:\/\/jassweb.com\/solved\/wp-content\/uploads\/2022\/10\/Solved-how-to-redirect-system-input-to-javaFX-textfield.gif\")
<\/a><\/p>\n<\/p><\/div>\n