ConcurrentModificationException при обновлении дерева JavaFX в фоновом режиме

Текущие ответы не помогают. Дело в том, что вы должны выполнить обновление дочерних элементов в основном потоке с помощью Platform.runLater

import javafx.application.Application;
import javafx.application.Platform;
import javafx.collections.ObservableList;
import javafx.scene.Scene;
import javafx.scene.control.TreeItem;
import javafx.scene.control.TreeView;
import javafx.scene.layout.HBox;
import javafx.stage.Stage;

import java.security.SecureRandom;
import java.util.Random;


public class Example extends Application {
    public static void main(String[] args) {
        launch(args);
    }

    @Override
    public void start(Stage stage) throws Exception {
        TreeView<String> treeView = new TreeView<String>(createNode("root"));
        HBox hBox = new HBox();
        hBox.getChildren().addAll(treeView);
        Scene scene = new Scene(hBox);
        stage.setScene(scene);
        stage.show();
    }

    Random r = new SecureRandom();

    public TreeItem<String> createNode(final String b) {
        return new TreeItem<String>(b) {
            private boolean isLeaf;
            private boolean isFirstTimeChildren = true;
            private boolean isFirstTimeLeaf = true;

            @Override
            public ObservableList<TreeItem<String>> getChildren() {
                if (isFirstTimeChildren) {
                    isFirstTimeChildren = false;
                    buildChildren(super.getChildren());
                }
                return super.getChildren();
            }

            @Override
            public boolean isLeaf() {
                if (isFirstTimeLeaf) {
                    isFirstTimeLeaf = false;
                    isLeaf = r.nextBoolean() && r.nextBoolean() && r.nextBoolean();
                }
                return isLeaf;
            }

            private void buildChildren(final ObservableList<TreeItem<String>> children) {
                if (!this.isLeaf()) {
                    Platform.runLater(new Runnable() {
                        @Override
                        public void run() {
                            int i;
                            int max = r.nextInt(500);
                            for (i = 0; i <= max; i++) {
                                children.addAll(new TreeItem[]{createNode("#" + r.nextInt())});
                            }
                        }
                    });
                }
            }
        };
    }
}

Этот парень столкнулся с той же проблемой: http://blog.idrsolutions.com/2012/12/handling-threads-concurrency-in-javafx/

Вы не можете напрямую изменить что-либо, что влияет на активные узлы и данные, связанные с графом сцены (включая элементы TreeView), из любого потока, кроме потока приложения JavaFX.

Примеры задач (те, которые вернуть ObservableList или частичные результаты), которые помогут вам решить вашу проблему. Вам нужно создать новые TreeItems в своей задаче в новом ObservableList, а затем, как только задача будет завершена (и в потоке приложения JavaFX), установите список элементов для вашего дерева в ObservableList, возвращенный из задачи.

http://docs.oracle.com/javafx/2/api/javafx/concurrent/Task.html

Вот обновленная версия вашего кода, которая следует некоторым из этих принципов и не имеет исключений ConcurrentModificationException.

Почему вызов addAll(List) не должен выполняться именно в тот момент, когда TreeItem вызывает updateExpandedDescidentCount()?

import javafx.application.Application;
import javafx.collections.FXCollections;
import javafx.collections.ObservableList;
import javafx.concurrent.Task;
import javafx.concurrent.WorkerStateEvent;
import javafx.event.EventHandler;
import javafx.scene.Scene;
import javafx.scene.control.TreeItem;
import javafx.scene.control.TreeView;
import javafx.scene.layout.HBox;
import javafx.stage.Stage;

import java.security.SecureRandom;
import java.util.Random;


public class ConcurrentExample extends Application {
  public static void main(String[] args) {
    launch(args);
  }

  @Override
  public void start(Stage stage) throws Exception {
    TreeView<String> treeView = new TreeView<>(createNode("root"));
    HBox hBox = new HBox();
    hBox.getChildren().addAll(treeView);
    Scene scene = new Scene(hBox);
    stage.setScene(scene);
    stage.show();
  }

  Random r = new SecureRandom();

  public TreeItem<String> createNode(final String b) {
    return new TreeItem<String>(b) {
      private boolean isLeaf;
      private boolean isFirstTimeChildren = true;
      private boolean isFirstTimeLeaf = true;

      @Override
      public ObservableList<TreeItem<String>> getChildren() {
        if (isFirstTimeChildren) {
          isFirstTimeChildren = false;
          buildChildren(super.getChildren());
        }
        return super.getChildren();
      }

      @Override
      public boolean isLeaf() {
        if (isFirstTimeLeaf) {
          isFirstTimeLeaf = false;
          isLeaf = r.nextBoolean() && r.nextBoolean() && r.nextBoolean();
        }
        return isLeaf;
      }

      private void buildChildren(final ObservableList<TreeItem<String>> children) {
        final ObservableList<TreeItem<String>> taskChildren = FXCollections.observableArrayList();

        if (!this.isLeaf()) {
          Task<Integer> task = new Task<Integer>() {
            @Override
            protected Integer call() throws Exception {
              int i;
              int max = r.nextInt(500);
              for (i = 0; i <= max; i++) {
                taskChildren.addAll(new TreeItem[]{createNode("#" + r.nextInt())});
              }
              return i;
            }
          };

          task.setOnSucceeded(new EventHandler<WorkerStateEvent>() {
            @Override public void handle(WorkerStateEvent workerStateEvent) {
              children.setAll(taskChildren);
            }
          });
          new Thread(task).start();
        }
      }
    };
  }

}

Обновление — описание того, почему решение работает

Приведенное выше решение не может получить ConcurrentModificationException, потому что задействованные ObservableLists никогда не изменяются одновременно.

• Коллекции taskChildren изменяются только в пользовательском потоке для задачи И
• Дочерние элементы дерева, активно прикрепленные к графу сцены, изменяются только в потоке приложения JavaFX для задачи.

Это обеспечивается следующими пунктами:

1. taskChildren.addAll вызывается в методе call задачи.
2. Метод вызова задачи вызывается в пользовательском потоке.
3. children.setAll(taskChildren) вызывается в потоке приложения JavaFX.
4. Система JavaFX гарантирует, что обработчик событий onSucceeded для задачи вызывается в потоке приложения JavaFX.
5. После завершения задачи в заданный список taskChildren больше не будут добавляться дочерние элементы, и этот список никогда не будет изменен.
6. Для каждой выполненной задачи создается новый список taskChildren, поэтому заданный список taskChildren никогда не используется совместно задачами.
7. Каждый раз, когда в дерево вносятся изменения, создается новая задача.
8. Семантика задачи такова, что данная задача может быть запущена только один раз и никогда не перезапускаться.
9. Дочерние элементы TreeItem, прикрепленные к активному графу сцены, изменяются только в потоке приложения JavaFX после успешного завершения задачи и прекращения обработки.

Почему вызов addAll(List) не должен выполняться именно в тот момент, когда TreeItem вызывает updateExpandedDescendentCount()?

updateExpandedDescendentCount() не является частью общедоступного API TreeItem — это метод внутренней реализации TreeView, который не имеет отношения к решению этой проблемы.

Обновить частичные обновления

В документации по задачам JavaFX есть решение для "Задачи Что возвращает частичные результаты». Используя что-то подобное, вы сможете решить проблему, заключающуюся в том, что «приложение непригодно для использования в начале, так как нужно дождаться завершения потока 'buildChildren', чтобы увидеть какие-либо узлы». Это связано с тем, что решение с частичным результатом позволит «передавать» результаты небольшими партиями из потока задачи компоновщика обратно в поток приложения FX.

Такое решение сложнее в реализации, чем то, которое я представил выше, но оно должно позволить вам иметь отзывчивый пользовательский интерфейс, соответствующий вашим требованиям. Как всегда, при работе с одновременными ситуациями необходимо проявлять особую осторожность, чтобы гарантировать, что общие данные не изменятся одновременно, вызывая потенциальные условия гонки, как вы испытали в своем исходном сообщении.

Это просто: вы продолжаете обновлять коллекцию, когда клиентский код начинает ее перебирать.

Удалите поток или убедитесь, что он завершен до создания итератора, или выполните какую-либо синхронизацию.