如何关闭 Apache Edgent 后台任务？答案

【问题标题】：How can I shutdown an Apache Edgent background task?如何关闭 Apache Edgent 后台任务？
【发布时间】：2018-06-27 22:37:08
【问题描述】：

ASUME以下代码SN-P：

TStream<Integer> stream = top.generate(() -> {            
  try{
    Thread.sleep(1500);
  }catch(InterruptedException ex){
    //DO NOTHING
  }
  return (int)(Math.random() * 100);
});

TWindow<Integer, Integer> window = stream.last(5, TimeUnit.SECONDS, zero());

TStream<Double> average = window.batch((values, key) -> {
  int sum = values.stream().mapToInt(Integer::intValue).sum();
  return (double)sum / values.size();
});

average.peek(average1 -> LOGGER.info("Calculated average : " + average1));
job = dp.submit(top);

调用job = dp.submit(top)后，执行拓扑的线程将继续在后台运行，直到JVM停止。

如何以编程方式停止此背景过程？当 Edgent 拓扑作为一个单独的进程与同一 JVM 中的其他任务一起运行时，这特别有用。我试图致电 @987654323 @，但这并不能解决问题。任务继续运行...

【问题讨论】：

标签： iot apache-edgent