从后台线程更新可观察列表的正确方法

Question

我试图按照MVC进行测试项目，所以我的模型应该完全独立于我的视图，但是我不知道如何更新Observable List在后台线程中更新（它被给予Strings关于通过FTP上传文件），以便消息出现在ListView中的UI上。

我正在使用JavaFX并试图让我的程序尽可能松散耦合。在当前时刻，视图包中的GUI取决于我的模型使用Platform.runLater（...）更新我的列表这一事实 - 据我所知，我的模型应该完全独立于视图，并且不应该“必须符合View的需求。

现在下面的代码实际上“按预期工作”，它只是没有正确建模，我不知道如何正确建模。一些最初的研究提出，我可能不得不使用观察者和可观察的 - 并在中间有另一个类作为我的可观察列表 - 但我不知道如何设置它。

所以我这是在后台线程更新可观察的名单：

private ObservableList<String> transferMessages; 

public FTPUtil(String host, int port, String user, String pass) { 
    this.host = host; 
    this.port = port; 
    this.username = user; 
    this.password = pass;  

    transferMessages = FXCollections.observableArrayList(); 

    connect(); 
} 

public void upload(File src) { 
    System.out.println("Uploading: " + src.getName()); 
    try { 
     if (src.isDirectory()) {    
      ftpClient.makeDirectory(src.getName()); 
      ftpClient.changeWorkingDirectory(src.getName()); 
      for (File file : src.listFiles()) { 
       upload(file); 
      } 
      ftpClient.changeToParentDirectory(); 
     } else { 
      InputStream srcStream = null; 
      try { 
       addMessage("Uploading: " + src.getName()); 
       srcStream = src.toURI().toURL().openStream(); 
       ftpClient.storeFile(src.getName(), srcStream); 
       addMessage("Uploaded: " + src.getName() + " - Successfully."); 

      } catch (Exception ex) { 
       System.out.println(ex); 
       addMessage("Error Uploading: " + src.getName() + " - Speak to Administrator."); 
      } 
     } 
    } catch (IOException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 

} 

private void addMessage(String message){ 

    Platform.runLater(() -> transferMessages.add(0, message)); 

} 

的FTPUtil类是我的模型。

我也有一个模型管理器类，这是什么控制这FTPUtil类：

public class ModelManager { 

private ObservableList<String> fileAndFolderLocations; 


private FTPUtil ftpUtil; 

public ModelManager(String host, int port, String user, String pass) { 

    ftpUtil = new FTPUtil(host, port, user, pass); 
    fileAndFolderLocations = FXCollections.observableArrayList(); 

} 

public boolean startBackup() { 

    Task task = new Task() { 
     @Override 
     protected Object call() throws Exception { 

      System.out.println("I started"); 
      ftpUtil.clearMessages(); 

      for(String location : fileAndFolderLocations){ 
       File localDirPath = new File(location);   
       ftpUtil.upload(localDirPath); 
      }    
      return null; 
     }   
    };  
    new Thread(task).start(); 

    return true; 
} 

public void addFileOrFolder(String fileOrFolder){ 
    if(!fileAndFolderLocations.contains(fileOrFolder)){ 
     fileAndFolderLocations.add(fileOrFolder); 
    }  
} 

public boolean removeFileOrFolder(String fileOrFolder){ 
    return fileAndFolderLocations.remove(fileOrFolder); 
} 

public ObservableList<String> getFilesAndFoldersList() { 
    return fileAndFolderLocations; 
} 

public ObservableList<String> getMessages() { 
    return ftpUtil.getMessages(); 
} 

} 

最后是我的GUI：

public class BackupController { 

private Main main; 
private ModelManager mm; 

@FXML 
private ListView<String> messagesList; 

@FXML 
void forceBackup(ActionEvent event) { 
    mm.startBackup();   

} 

public void initController(Main main, ModelManager mm) { 
    this.main = main; 
    this.mm = mm; 

    messagesList.setItems(mm.getMessages()); 
} 


} 

Answer 1

基本设置：

• 不在模型中使用Platform.runLater
• 请勿设置模型/管理消息直接作为项目到ListView
• 也保持项目的独立的observableList，并设置到列表
• 安装管理器的列表上的听众，保持与信息同步的项目的读者的名单：包裹在这些修改Platform.runLater

一个非常原始片断来说明设置：

private Parent getContent() { 
    ModelManager manager = new ModelManager(); 
    ObservableList<String> uploading = FXCollections.observableArrayList("one", "two", "three"); 

    ObservableList<String> items = FXCollections.observableArrayList(); 
    manager.getMessages().addListener((ListChangeListener) c -> { 

     while (c.next()) { 
      if (c.wasAdded()) { 
       Platform.runLater(() -> 
        items.addAll(c.getFrom(), c.getAddedSubList())); 
      } 
      if (c.wasRemoved()) { 
       Platform.runLater(() -> 
        items.removeAll(c.getRemoved())); 
      } 
     } 
    }); 


    ListView<String> list = new ListView<>(items); 
    Button button = new Button("start"); 
    button.setOnAction(ev -> { 
     uploading.stream().forEach(e -> manager.addFile(e)); 
     manager.startBackup(); 
    }); 
    BorderPane pane = new BorderPane(list); 
    pane.setBottom(button); 
    return pane; 
} 

@Override 
public void start(Stage stage) throws Exception { 
    Scene scene = new Scene(getContent()); 
    stage.setScene(scene); 
    stage.show(); 
}