Java ExecutorService, newVirtualThreadPerTaskExecutor: поток завершается до получения входных данных от сканера ⇐ JAVA

[Anonymous]

У меня есть простой код для получения имени пользователя в первом потоке, добавления его в очередь и печати имен с помощью второго потока:

Код: Выделить всё

import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;

public class TestThreads {
private static final Scanner scanner = new Scanner(System.in);
private static ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor();
private static LinkedBlockingQueue names = new LinkedBlockingQueue();

public static void main(String[] args) {
executor.submit(() -> {
try {
while (true) {
String name = getName();
names.add(name);
}
} catch (Exception e)  {
e.printStackTrace();
}
});

executor.submit(() -> {
try {
while (true) {
if (!names.isEmpty())  {
String name = names.poll();
System.out.println("\n**** The name is " + name + " ****\n");
}
}
} catch (Exception e)  {
e.printStackTrace();
}
});
}

private static String getName()  {
System.out.print("Enter a name: ");
return scanner.nextLine();
}
}

Однако результат

Код: Выделить всё

Enter a name:
Process finished with exit code 0

Программа завершает работу до того, как пользователь сможет ввести какое-либо имя, несмотря на бесконечные циклы while. Что я делаю не так?

Подробнее здесь: https://stackoverflow.com/questions/777 ... s-before-g