JavaFX update ObservableList with extractor，用于UI中的非JavaFX线程

Question

ObservableList<Person> secondList = FXCollections.observableArrayList();
secondList.addAll(originalList);
originalList.addListener((ListChangeListener<? super Person>)change-> {
    while(change.next()) {
        if (change.wasRemoved()) {
            Platform.runLater(() -> secondList.subList(change.getFrom(), change.getFrom() + change.getRemovedSize()).clear());
        }

        if (change.wasAdded()) {
            Platform.runLater(() -> secondList.addAll(change.getFrom(), change.getAddedSubList()));
        }
    }
});
ListView<Person> listViewPerson = new ListView<>(secondList);

ObservableList<Person> secondList = FXCollections.observableArrayList(person -> new Observable[]{person.adultProperty()});

public PersonUI(Person person) {
    adult = new SimpleBooleanProperty(person.isAdult());
    person.adultProperty().addListener((observableValue, oldValue, newValue) -> {
        Platform.runLater(() -> this.adult.set(newValue));
    });
}

还有其他的解决办法吗？如果我目前的解决方案有任何问题，请指出。

Answer 1

/**
 * A 1:1 transform of the sourceList that guarantees to fire change notification
 * on the fx-thread.
 * 
 * @author Jeanette Winzenburg, Berlin
 */
public class FXThreadTransformationList<E> extends TransformationList<E, E> {

    public FXThreadTransformationList(ObservableList<E> source) {
        super(source);
    }

    @Override
    protected void sourceChanged(Change<? extends E> c) {
        beginChange();
        while (c.next()) {
            if (c.wasPermutated()) {
                // tbd
            } else if (c.wasUpdated()) {
                update(c);
            } else if (c.wasReplaced()) {
                // tbd
            } else {
                addedOrRemoved(c);
            }
        }
        // commit on fx-thread
        endChangeOnFXThread();
    }

    public void endChangeOnFXThread() {
        Platform.runLater(() -> endChange());
    }

    private void addedOrRemoved(Change<? extends E> c) {
        if (c.wasRemoved()) {
            nextRemove(c.getFrom(), c.getRemoved());
        } else if (c.wasAdded()) {
            nextAdd(c.getFrom(), c.getTo());  
        } else {
            throw new IllegalStateException("expected either removed or added, but was:" + c);
        }
    }

    private void update(Change<? extends E> c) {
        for (int pos = c.getFrom(); pos < c.getTo(); pos++) {
            nextUpdate(pos);
        }
    }

    @Override
    public int getViewIndex(int index) {
        return index;
    }

    @Override
    public int getSourceIndex(int index) {
        return index;
    }

    @Override
    public E get(int index) {
        return getSource().get(index);
    }

    @Override
    public int size() {
        return getSource().size();
    }

    @SuppressWarnings("unused")
    private static final Logger LOG = Logger
            .getLogger(FXThreadTransformationList.class.getName());
}