使用多个任务将问题分解为位。使用控制任务来监控子任务的状态和整体进度。使用java.util.concurrent类来管理任务执行、排序和数据结构,例如LinkedBlockingDeque。
这个推荐的解决方案不是解决您的问题的最简单的解决方案,但如果做得好应该可以提供良好的用户体验。
有关应用于不同问题的分而治之方法的示例,请参见以下代码示例:
- 将复杂的流程拆分为多个托管子任务。
- 演示了对多个工作人员按顺序或并行执行的管理。
一种潜在的简单替代方法是在整个过程中使用一个,并通过根据需要从您的任务代码Task
调用将您的多个反馈值报告回您的 JavaFX UI 。Platform.runLater
有关此方法的示例,请参阅任务文档部分“修改场景图的任务” 。
这是在一次Platform.runLater
调用中一次更新多个标签的东西。
Platform.runLater(new Runnable() {
@Override public void run() {
status.setText("");
folderCount.setText("");
fileCount.setText("");
mp3Count.setText("");
}
});
还有一些类似于您的示例的代码:
import java.util.Arrays;
import java.util.List;
import static javafx.application.Application.launch;
import javafx.application.*;
import javafx.beans.value.*;
import javafx.concurrent.Task;
import javafx.event.*;
import javafx.scene.*;
import javafx.scene.control.*;
import javafx.scene.layout.*;
import javafx.stage.Stage;
public class Mp3Finder extends Application {
final Label status = new Label();
final Label folderCount = new Label();
final Label fileCount = new Label();
final Label mp3Count = new Label();
@Override public void start(Stage stage) {
final GridPane finderResults = new GridPane();
finderResults.setPrefWidth(400);
finderResults.setVgap(10);
finderResults.setHgap(10);
finderResults.addRow(0, new Label("Status: "), status);
finderResults.addRow(1, new Label("# Folders: "), folderCount);
finderResults.addRow(2, new Label("# Files: "), fileCount);
finderResults.addRow(3, new Label("# mp3s: "), mp3Count);
final Button finderStarter = new Button("Find mp3s");
finderStarter.setOnAction(new EventHandler<ActionEvent>() {
@Override public void handle(ActionEvent t) {
startMp3Finder(finderStarter);
}
});
VBox layout = new VBox(10);
layout.setStyle("-fx-background-color: cornsilk; -fx-padding: 10; -fx-font-size: 16;");
layout.getChildren().setAll(finderStarter, finderResults);
stage.setScene(new Scene(layout));
stage.show();
}
private void startMp3Finder(final Node starterNode) {
starterNode.setDisable(true);
Mp3FinderTask task = new Mp3FinderTask(status, folderCount, mp3Count);
task.runningProperty().addListener(new ChangeListener<Boolean>() {
@Override public void changed(ObservableValue<? extends Boolean> ov, Boolean wasRunning, Boolean isRunning) {
if (!isRunning) {
starterNode.setDisable(false);
}
}
});
final Thread thread = new Thread(task , "mp3-finder");
thread.setDaemon(true);
thread.start();
}
private class Mp3FinderTask extends Task<List<String>> {
private final Label status;
private final Label folderCount;
private final Label mp3Count;
public Mp3FinderTask(Label status, Label folderCount, Label mp3Count) {
this.status = status;
this.folderCount = folderCount;
this.mp3Count = mp3Count;
}
@Override protected List<String> call() throws Exception {
initFinderResults();
updateLabelLater(status, "Finding Folders");
setProgressIndicator(folderCount);
List folders = findFolders();
updateLabelLater(folderCount, folders.size() + "");
updateLabelLater(status, "Finding Files");
setProgressIndicator(fileCount);
List files = findFiles(folders);
updateLabelLater(fileCount, files.size() + "");
updateLabelLater(status, "Find mp3s");
setProgressIndicator(mp3Count);
List mp3s = findMp3s(files);
updateLabelLater(mp3Count, mp3s.size() + "");
updateLabelLater(status, "All mp3s Found");
return mp3s;
}
void updateLabelLater(final Label label, final String text) {
Platform.runLater(new Runnable() {
@Override public void run() {
label.setGraphic(null);
label.setText(text);
}
});
}
private List<String> findFolders() throws InterruptedException {
// dummy implementation
Thread.currentThread().sleep(1000);
return Arrays.asList("folder1", "folder2", "folder3");
}
private List<String> findFiles(List<String> folders) throws InterruptedException {
// dummy implementation
Thread.currentThread().sleep(1000);
return Arrays.asList("file1", "file2", "file3", "file4", "file5");
}
private List<String> findMp3s(List<String> files) throws InterruptedException {
// dummy implementation
Thread.currentThread().sleep(1000);
return Arrays.asList("music1", "music2");
}
private void initFinderResults() {
Platform.runLater(new Runnable() {
@Override public void run() {
status.setText("");
folderCount.setText("");
fileCount.setText("");
mp3Count.setText("");
}
});
}
private void setProgressIndicator(final Label label) {
Platform.runLater(new Runnable() {
@Override public void run() {
label.setGraphic(new ProgressIndicator());
}
});
}
}
public static void main(String[] args) { launch(args); }
}
有关更多信息,请参阅有关使用 Platform.runLater 和从不同线程访问 UI的 StackOverflow 问题,以及指向有关 JavaFX 中的并发性的更多资源的链接。