我创建了一个示例解决方案，用于使用任务（如 Alexander Kirov 的评论中所建议）来访问 JavaFX 应用程序线程的并发执行线程上的数据库。
示例解决方案的相关部分转载如下：
// fetches a collection of names from a database.
class FetchNamesTask extends DBTask<ObservableList<String>> {
@Override protected ObservableList<String> call() throws Exception {
// artificially pause for a while to simulate a long
// running database connection.
Thread.sleep(1000);
try (Connection con = getConnection()) {
return fetchNames(con);
}
}
private ObservableList<String> fetchNames(Connection con) throws SQLException {
logger.info("Fetching names from database");
ObservableList<String> names = FXCollections.observableArrayList();
Statement st = con.createStatement();
ResultSet rs = st.executeQuery("select name from employee");
while (rs.next()) {
names.add(rs.getString("name"));
}
logger.info("Found " + names.size() + " names");
return names;
}
}
// loads a collection of names fetched from a database into a listview.
// displays a progress indicator and disables the trigge button for
// the operation while the data is being fetched.
private void fetchNamesFromDatabaseToListView(
final Button triggerButton,
final ProgressIndicator databaseActivityIndicator,
final ListView listView) {
final FetchNamesTask fetchNamesTask = new FetchNamesTask();
triggerButton.setDisable(true);
databaseActivityIndicator.setVisible(true);
databaseActivityIndicator.progressProperty().bind(fetchNamesTask.progressProperty());
fetchNamesTask.setOnSucceeded(new EventHandler<WorkerStateEvent>() {
@Override public void handle(WorkerStateEvent t) {
listView.setItems(fetchNamesTask.getValue());
}
});
fetchNamesTask.runningProperty().addListener(new ChangeListener<Boolean>() {
@Override public void changed(ObservableValue<? extends Boolean> observable, Boolean wasRunning, Boolean isRunning) {
if (!isRunning) {
triggerButton.setDisable(false);
databaseActivityIndicator.setVisible(false);
}
};
});
databaseExecutor.submit(fetchNamesTask);
}
private Connection getConnection() throws ClassNotFoundException, SQLException {
logger.info("Getting a database connection");
Class.forName("org.h2.Driver");
return DriverManager.getConnection("jdbc:h2:~/test", "sa", "");
}
abstract class DBTask<T> extends Task<T> {
DBTask() {
setOnFailed(new EventHandler<WorkerStateEvent>() {
@Override public void handle(WorkerStateEvent t) {
logger.log(Level.SEVERE, null, getException());
}
});
}
}
// executes database operations concurrent to JavaFX operations.
private ExecutorService databaseExecutor = Executors.newFixedThreadPool(
1,
new DatabaseThreadFactory()
);
static class DatabaseThreadFactory implements ThreadFactory {
static final AtomicInteger poolNumber = new AtomicInteger(1);
@Override public Thread newThread(Runnable runnable) {
Thread thread = new Thread(runnable, "Database-Connection-" + poolNumber.getAndIncrement() + "-thread");
thread.setDaemon(true);
return thread;
}
}
请注意，一旦您开始同时执行操作，当一切都是单线程时，您的编码和 UI 会比没有任务的默认模式更复杂。例如，在我的示例中，我禁用了启动任务的按钮，因此您不能让多个任务在后台运行做同样的事情（这种处理类似于网络世界，您可能会禁用表单发布按钮以防止表格被双重张贴）。当长时间运行的数据库任务正在执行时，我还在场景中添加了一个动画进度指示器，以便用户可以指示正在发生的事情。
示例程序输出演示了长时间运行的数据库操作正在进行时的 UI 体验（请注意，在获取期间进度指示器正在动画，这意味着 UI 是响应式的，尽管屏幕截图没有显示这一点）：
为了比较具有并发任务的实现与在 JavaFX 应用程序线程上执行所有内容的实现的额外复杂性和功能，您可以看到不使用任务的同一示例的另一个版本。请注意，在我使用玩具本地数据库的情况下，基于任务的应用程序的额外复杂性是不必要的，因为本地数据库操作执行得非常快，但是如果您使用长时间运行的复杂查询连接到大型远程数据库，则基于任务的应用程序这种方法是值得的，因为它为用户提供了更流畅的 UI 体验。