From c4a6cf65e1851d85cf104ea21e2921a98089b6a9 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期二, 16 一月 2024 15:36:45 +0800 Subject: [PATCH] 1、通信中间件实现控制器自报数据处理逻辑,及实现数据库映射Mapper。 --- pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/java/com/dy/aceMw/server/rtuData/RtuDataNode.java | 12 ++++++------ 1 files changed, 6 insertions(+), 6 deletions(-) diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/java/com/dy/aceMw/server/rtuData/RtuDataNode.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/java/com/dy/aceMw/server/rtuData/RtuDataNode.java index d007230..09ee99e 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/java/com/dy/aceMw/server/rtuData/RtuDataNode.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/java/com/dy/aceMw/server/rtuData/RtuDataNode.java @@ -25,18 +25,18 @@ pool.putJob(new ThreadPool.Job() { public void execute() { if(obj != null){ - TaskSurpport t = null ; + TaskSurpport task = null ; try{ - t = TaskPool.popTask() ; - if(t != null){ - t.execute(obj); + task = TaskPool.popTask() ; + if(task != null){ + task.execute(obj); }else{ log.error("鏈緱鍒癛TU涓诲姩涓婃姤鏁版嵁澶勭悊浠诲姟锛�"); } }catch(Exception e){ - if(t != null){ + if(task != null){ //褰撴湁寮傚父鏃讹紝try catch涓殑浠g爜鍙病鏈夋墽琛宖reeAndCleanTask - TaskPool.freeAndCleanTask(t); + TaskPool.freeAndCleanTask(task); } } } -- Gitblit v1.8.0