瀏覽代碼

计数线程处理调整

master
林万龙 3 年之前
父節點
當前提交
23ca592b1e
共有 1 個檔案被更改,包括 8 行新增6 行删除
  1. +8
    -6
      src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java

+ 8
- 6
src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java 查看文件

@@ -26,6 +26,13 @@ public class IotMessageListener implements MessageListener {
private Runnable runnable;

public IotMessageListener() {

}

private ExecutorService executorService;
public void setExecutorService(ExecutorService executorService) {

this.executorService = executorService;
this.runnable = new Runnable() {
//创建 run 方法
@Override
@@ -43,12 +50,7 @@ public class IotMessageListener implements MessageListener {
// 第二个参数为首次执行的延时时间,第三个参数为定时执行的间隔时间
// 10:秒 5:秒
// 第一次执行的时间为10秒,然后每隔五秒执行一次
service.scheduleAtFixedRate(runnable, 30, 60, TimeUnit.SECONDS);
}

private ExecutorService executorService;
public void setExecutorService(ExecutorService executorService) {
this.executorService = executorService;
service.scheduleAtFixedRate(runnable, 90, 60, TimeUnit.SECONDS);
}

@Override


Loading…
取消
儲存