notifyAll() 后函数继续，但函数返回后线程终止

Question

基本上，线程 A wait() 在锁定对象上，然后是线程 B notifyAll()。线程 A 上的函数完成，但不返回正常操作。

值得注意的是，我使用的是 JavaFX。为了将我的 FX 线程与我的工作线程分开，我创建了一个新线程以防止在我锁定它时出现问题等。

这是我的代码（简化为有问题的函数）：

public class ShortcutManager {

    private static final StringProperty STATE = new SimpleStringProperty("Create Shortcut");

    public static void create() {
        Thread creationThread = new Thread(() -> {
            // Do some work (sends logs to the logger)
            String result = prompt();
            if (result != null) {
                // Do more work (sends logs to the logger)
            } else {
                // Do other work (sends logs to the logger)
            }
        }
        creationThread.start();
    }

private static String prompt() {
    STATE.setValue("Waiting for user...");
    String result = popup.showAndWait();
    System.out.println("Result: \"" + result + "\"");
    return result;
}

public class CmlPopup implements Initializable {

    private boolean isClosed = false;

    public synchronized String showAndWait() {
        isClosed = false;
        Platform.runLater(() -> {
            stage.show();
        });
        while (!isClosed) {
            try {
                System.out.println("Waiting.");
                wait();
                System.out.println("Notified.");
            } catch (InterruptedException ex) {

            }
        }
        return getResult();
    }

    public synchronized void close() {
        stage.close();
        isClosed = true;
        System.out.println("Closing and notifying");
        notifyAll();
    }

}

现在 - 当舞台有 showAndWait() 函数时，为什么我要自己锁定它？因为这也不起作用，而且它最终会暂停 FX 线程而不是创建线程，因为 show() 和 showAndWait() 都必须在 FX 线程上发生。

我的输出如下：

. . .

ShortcutManager State: Waiting for user...
Waiting.
Closing and notifying.
Notified.

然后仅此而已。不打印结果；线程没有其他工作。我的 FX 线程和其他工作线程运行良好，但这个似乎只是终止，即使还有更多工作要做。

附：在你批评我之前，我在打算保留它们的地方使用 Loggers，而当我打算删除它们时使用 System.out。

Answer 1

首先 - 感谢那些提供评论的乐于助人的人。尽管您的解决方案对我不起作用，但它们为我指明了正确的方向。

现在，我的解决方案是：我只是将弹出结果、阻塞等包装在 CompletableFuture 中。

public class CmlPopup<R, D> implements Initializable {
    
    private final Object closeLock = new Object();
    private volatile boolean isClosed = false;

    ----

    public CompletableFuture<R> showAndGet() {
        Platform.runLater(() -> {
            stage.show();
        });
        return CompletableFuture.supplyAsync(() -> {
            synchronized (closeLock) {
                while (!isClosed) {
                    try {
                        closeLock.wait();
                    } catch (InterruptedException ex) {
                        
                    }
                }
                return contentManager.getResult();
            }
        }

    public void showThenRun(BiConsumer<? super R, ? super Throwable> action) {
        CompletableFuture.supplyAsync(() -> {
            synchronized (closeLock) {
                while (!isClosed) {
                    try {
                        closeLock.wait();
                    } catch (InterruptedException ex) {
                        
                    }
                }
                return contentManager.getResult();
            }
        }).whenComplete(action);
        Platform.runLater(() -> {
            stage.show();
        });
    }

    public void close() {
        stage.close();
        synchronized (closeLock) {
            isClosed = true;
            closeLock.notifyAll();
        }
    }

}

public class ShortcutManager {

    private static final CmlPopup<String, Integer> POPUP = new CmlPopup(...);

    ----

    private static void prompt(File userData) {
        POPUP.showThenRun((String result, Throwable ex) -> {
            System.out.println("Result: \"" + result+ "\"");
            ShortcutManager.identifyAndGridImages(result, userData);
        });
    }
    
    ----
    
}

这完全可靠。无论出于何种原因，对象本身的 CompletableFuture 永远不会运行 whenComplete 函数，即使未来被认为是“完整的”。