JavaFX -从线程实时更新lineChart

import javafx.application.Application;
import javafx.application.Platform;
import javafx.scene.Scene;
import javafx.scene.chart.LineChart;
import javafx.scene.chart.NumberAxis;
import javafx.scene.chart.XYChart;
import javafx.stage.Stage;

import java.util.Random;

public class RealTimeLineChartExample extends Application {

    private static final int MAX_DATA_POINTS = 50;
    private static final int MAX_RANDOM_VALUE = 100;

    private XYChart.Series<Number, Number> series;
    private int xAxisData = 0;

    @Override
    public void start(Stage primaryStage) {
        primaryStage.setTitle("Real-time Line Chart Example");

        // 创建x轴和y轴
        final NumberAxis xAxis = new NumberAxis();
        final NumberAxis yAxis = new NumberAxis();
        xAxis.setLabel("Time");
        yAxis.setLabel("Value");

        // 创建LineChart并设置初始数据
        final LineChart<Number, Number> lineChart = new LineChart<>(xAxis, yAxis);
        lineChart.setTitle("Real-time Line Chart");
        series = new XYChart.Series<>();
        lineChart.getData().add(series);

        // 创建场景并显示
        Scene scene = new Scene(lineChart, 800, 600);
        primaryStage.setScene(scene);
        primaryStage.show();

        // 启动后台线程更新数据
        Thread dataUpdateThread = new Thread(this::updateData);
        dataUpdateThread.setDaemon(true);
        dataUpdateThread.start();
    }

    // 后台线程更新数据
    private void updateData() {
        Random random = new Random();
        while (true) {
            try {
                // 模拟获取最新数据
                int newData = random.nextInt(MAX_RANDOM_VALUE);

                // 更新数据模型
                Platform.runLater(() -> {
                    series.getData().add(new XYChart.Data<>(xAxisData++, newData));
                    if (series.getData().size() > MAX_DATA_POINTS) {
                        series.getData().remove(0);
                    }
                });

                // 等待一段时间
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) {
        launch(args);
    }
}