如何在JAVAFX 2中使用区域图表绘制实时数据图表 - 并发,动画,图表

2022-09-03 16:15:40

要求 - 使用实时流数据构建动画区域图。也许每1秒绘制300个数据点。

详细信息 - 因此,我需要从医疗设备读取患者呼吸模式的实时流数据,并使用JavaFX中的AreaChart以波形方式显示它。我是JavaFX的新手,所以我构建了一个小的POC,看看并发和动画在JavaFX中是如何工作的。

这个概念是有效的,就实现功能而言,我对基本测试感到满意。但是我对从下面的代码中获得的性能不满意。

在下面的工作代码中,我创建了一个单独的线程来模拟从医疗设备获取数据。线程只是生成一个随机数,并将其添加到 ConcurrentLinkedQueue 中。

JavaFX 应用程序线程通过时间轴将此数据从队列中拉出,并将其添加到 AreaChart 系列中。

这为我提供了所需的动画,并且正在运行时添加数据。您可以复制粘贴此代码并对其进行测试。它应该有效。

但是性能并不令人印象深刻 - CPU使用率为56% - 我的笔记本电脑上有一个英特尔酷睿2双核@ 2.53 GHZ和4GB RAM。我的显卡是移动式英特尔 4 系列快车,带有最新的驱动程序。

如何改进此动画或实时数据的绘图,以获得更好的性能?

注意:我愿意在动画上妥协,如果它是瓶颈。我对如下所示的实现持开放态度,http://smoothiecharts.org/ 其中波形只是预构建的,只是从右到左流式传输。

  import java.util.concurrent.ConcurrentLinkedQueue;
  import java.util.concurrent.ExecutorService;
  import java.util.concurrent.Executors;
  import java.util.logging.Level;
  import java.util.logging.Logger;
  import javafx.animation.Animation;
  import javafx.animation.KeyFrame;
  import javafx.animation.SequentialTransition;
  import javafx.animation.Timeline;
  import javafx.application.Application;
  import javafx.event.ActionEvent;
  import javafx.event.EventHandler;
  import javafx.scene.Group;
  import javafx.scene.Scene;
  import javafx.scene.chart.AreaChart;
  import javafx.scene.chart.NumberAxis;
  import javafx.scene.chart.XYChart.Series;
  import javafx.stage.Stage;
  import javafx.util.Duration;

  /**
   * A chart that fills in the area between a line of data points and the axes.
   * Good for comparing accumulated totals over time.
   *
   * @see javafx.scene.chart.Chart
   * @see javafx.scene.chart.Axis
   * @see javafx.scene.chart.NumberAxis
   * @related charts/line/LineChart
   * @related charts/scatter/ScatterChart
   */
  public class AreaChartSample extends Application {
      private Series series;
      private int xSeriesData=0;
      private ConcurrentLinkedQueue<Number> dataQ = new ConcurrentLinkedQueue<Number>();
      private ExecutorService executor;
      private AddToQueue addToQueue;
      private Timeline timeline2;
      private SequentialTransition animation;

      private void init(Stage primaryStage) {
          Group root = new Group();
          primaryStage.setScene(new Scene(root));

          NumberAxis xAxis = new NumberAxis();
          xAxis.setAutoRanging(true);

          NumberAxis yAxis = new NumberAxis();
          yAxis.setAutoRanging(true);

          //-- Chart
          final AreaChart<Number,Number> sc = new AreaChart<Number,Number>(xAxis,yAxis);
          sc.setId("liveAreaChart");
          sc.setTitle("Animated Area Chart");

          //-- Chart Series
          series=new AreaChart.Series<Number,Number>();
          series.setName("Area Chart Series");
          series.getData().add(new AreaChart.Data<Number, Number>(5d, 5d));
          sc.getData().add(series);


          root.getChildren().add(sc);



      }

      @Override public void start(Stage primaryStage) throws Exception {
          init(primaryStage);
          primaryStage.show();

          //-- Prepare Executor Services
          executor = Executors.newCachedThreadPool();
          addToQueue=new AddToQueue();
          executor.execute(addToQueue);


          //-- Prepare Timeline
          prepareTimeline();


      }

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

      private class AddToQueue extends Thread {

          public void run(){

          try {
              Thread.currentThread().setName(Thread.currentThread().getId()+"-DataAdder");
              //-- Add Random numbers to Q
              dataQ.add(Math.random());
              Thread.sleep(50);

              executor.execute(addToQueue);

          } catch (InterruptedException ex) {
              Logger.getLogger(AreaChartSample.class.getName()).log(Level.SEVERE, null, ex);
          }

          }
      }

      //-- Timeline gets called in the JavaFX Main thread
      private void prepareTimeline(){
          //-- Second slower timeline
          timeline2 = new Timeline();
          //-- This timeline is indefinite.  
          timeline2.setCycleCount(Animation.INDEFINITE);

          timeline2.getKeyFrames().add(
                  new KeyFrame(Duration.millis(100), new EventHandler<ActionEvent>() {
                      @Override public void handle(ActionEvent actionEvent) {
                          addDataToSeries();

                      }
                  })
          );

          //-- Set Animation- Timeline is created now.
          animation = new SequentialTransition();
          animation.getChildren().addAll(timeline2);
          animation.play();        

      }

      private void addDataToSeries(){

          for(int i=0;i<20;i++){ //-- add 20 numbers to the plot
              if(dataQ.isEmpty()==false)   {
                  series.getData().add(new AreaChart.Data(xSeriesData++,dataQ.remove()));

                  //-- Get rid of a bunch from the chart
                  if (series.getData().size() > 1000) {
                      series.getData().remove(0,999);
                  }

              }
              else{
                  return;
              }
          }
      }


  }

答案 1

正如jewelsea在他/她的评论中所说:

这个问题在Oracle JavaFX论坛线程上交叉发布(并回答得很好)。

总而言之,解决方案包括:

  • 关闭动画,因为它是为较慢的数据变化而设计的,因此在到达时会进行动画处理;
  • 根据需要将 更改为 a,以便每帧更新图表,以便与传入的数据保持同步并尽可能平稳地移动;TimelineAnimationTimer
  • 将线程修复为OP在使用执行器时不需要扩展线程。更改执行程序服务的创建。

答案 2

性能大幅下降可能来自您的数据收集。没有理由使用一个并不断添加新的由它执行,以获得重复的数据添加。您可以满足于单个线程,该线程读取/接收数据并将其添加到队列中,并通过调用 来启动它。为了使它正常工作,您希望循环在线程中连续运行,并在每次迭代结束时出现延迟。ExecutorServiceThreadsaddToQueue.start()


推荐