JavaFX多线程场景：数组与ObservableList的性能及异常问题

异常原因定位 #

从堆栈信息来看，UnsupportedOperationException 是在JavaFX的ListChangeBuilder尝试向不可修改集合添加元素时触发的，根源在于后台线程直接修改JavaFX ObservableList：

• JavaFX的ObservableList默认绑定FX应用线程，后台线程（ScheduledExecutorService的线程）直接修改会破坏其内部线程安全状态，导致内部维护的变更监听集合变为不可修改状态，进而在执行set操作时抛出异常。
• 高频调用会放大线程冲突问题，同时因为每次修改都要触发FX线程的监听通知，直接导致性能下降。

核心解决方案 #

1. 强制在FX应用线程修改ObservableList #

所有对ObservableList的修改操作必须通过Platform.runLater包裹，确保在FX线程执行：

// 替换原直接修改的代码
Platform.runLater(() -> {
    dmxDataObservable.setByte(index, value);
});

2. 优化高频更新的性能 #

高频调用场景下，频繁调用Platform.runLater会导致FX线程任务队列拥堵，建议采用批量更新+定时同步的方式：

• 后台线程仅更新临时数据缓冲区（比如用AtomicReference存储字节数组）
• 在FX线程通过Timeline定时批量同步缓冲区数据到ObservableList

示例代码：

// 后台线程数据缓冲区
private final AtomicReference<byte[]> dataBuffer = new AtomicReference<>(new byte[512]);

// 后台线程定时更新缓冲区
scheduledExecutor.scheduleAtFixedRate(() -> {
    byte[] newData = generateNewDMXData(); // 生成摇头灯控制数据
    dataBuffer.set(newData);
}, 0, 10, TimeUnit.MILLISECONDS);

// FX线程定时批量同步到ObservableList
Timeline syncTimeline = new Timeline(new KeyFrame(Duration.millis(10), event -> {
    byte[] latestData = dataBuffer.get();
    for (int i = 0; i < latestData.length; i++) {
        dmxDataObservable.set(i, latestData[i]);
    }
}));
syncTimeline.setCycleCount(Animation.INDEFINITE);
syncTimeline.play();

3. 检查ObservableList实现正确性 #

确保自定义的dmxDataObservable类正确实现ModifiableObservableListBase的抽象方法，内部存储必须是可修改集合（比如ArrayList而非Collections.unmodifiableList）：

public class dmxDataObservable extends ModifiableObservableListBase<Byte> {
    private final List<Byte> internalData = new ArrayList<>();

    @Override
    public Byte get(int index) {
        return internalData.get(index);
    }

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

    @Override
    protected void doSet(int index, Byte oldValue, Byte newValue) {
        internalData.set(index, newValue);
    }

    @Override
    protected void doAdd(int index, Byte element) {
        internalData.add(index, element);
    }

    @Override
    protected Byte doRemove(int index) {
        return internalData.remove(index);
    }

    public void setByte(int index, int value) {
        set(index, (byte) value);
    }
}

内容的提问来源于stack exchange，提问作者droid