ThbTech/SmartSubstationPlatform
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化代码

Browse Source
This commit is contained in:
weitang 2025-04-25 08:52:02 +08:00
parent 94b13ac2f7
commit 3fdf153036
2 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
riis-system/src/main/java/com/yfd/platform/component/iec104/core/OptimizedThreadPool.java
View File

@ -1,5 +1,7 @@
package com.yfd.platform.component.iec104.core; package com.yfd.platform.component.iec104.core;
import org.jetbrains.annotations.NotNull;
import java.util.concurrent.*; import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
@ -54,7 +56,7 @@ public final class OptimizedThreadPool {
public void execute(Runnable task) { public void execute(Runnable task) {
// 添加基础校验（生产环境可扩展） // 添加基础校验（生产环境可扩展）
if (task == null) { if (task == null) {
throw new IllegalArgumentException("Task cannot be null"); throw new IllegalArgumentException("任务不能为空");
} }
// 添加异常处理包装 // 添加异常处理包装
@ -70,7 +72,7 @@ public final class OptimizedThreadPool {
task.run(); task.run();
} catch (Exception e) { } catch (Exception e) {
// 统一的异常处理（建议接入日志系统） // 统一的异常处理（建议接入日志系统）
System.err.println("Task execution failed: " + e.getMessage()); System.err.println("任务执行失败: " + e.getMessage());
e.printStackTrace(); e.printStackTrace();
} }
}; };
@ -115,7 +117,7 @@ public final class OptimizedThreadPool {
private static final String THREAD_NAME_PREFIX = "optimized-pool-thread-"; private static final String THREAD_NAME_PREFIX = "optimized-pool-thread-";
@Override @Override
public Thread newThread(Runnable r) { public Thread newThread(@NotNull Runnable r) {
Thread thread = new Thread(r, THREAD_NAME_PREFIX + threadCounter.getAndIncrement()); Thread thread = new Thread(r, THREAD_NAME_PREFIX + threadCounter.getAndIncrement());
thread.setDaemon(false); // 非守护线程 thread.setDaemon(false); // 非守护线程
thread.setPriority(Thread.NORM_PRIORITY); thread.setPriority(Thread.NORM_PRIORITY);

18
riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/DeviceWorkDataServiceImpl.java
View File

@ -55,15 +55,15 @@ public class DeviceWorkDataServiceImpl extends ServiceImpl<DeviceWorkDataMapper,
workdata.setSignalId(map.get("signalId").toString()); workdata.setSignalId(map.get("signalId").toString());
workdata.setSignalName(map.get("signalName").toString()); workdata.setSignalName(map.get("signalName").toString());
workdata.setUnit(ObjUtil.isNotEmpty(map.get("signalUnit")) ? map.get("signalUnit").toString() : ""); workdata.setUnit(ObjUtil.isNotEmpty(map.get("signalUnit")) ? map.get("signalUnit").toString() : "");
workdata.setValue(new BigDecimal(value)); workdata.setValue(new BigDecimal(value));
if (StrUtil.isEmpty(dateTimeString) || "null".equals(dateTimeString)) { if (StrUtil.isEmpty(dateTimeString) || "null".equals(dateTimeString)) {
workdata.setStartTime(LocalDateTime.now()); workdata.setStartTime(LocalDateTime.now());
} else { } else {
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS"); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS");
LocalDateTime localDateTime = LocalDateTime.parse(dateTimeString, formatter); LocalDateTime localDateTime = LocalDateTime.parse(dateTimeString, formatter);
workdata.setStartTime(localDateTime); workdata.setStartTime(localDateTime);
} }
this.saveOrUpdate(workdata); this.saveOrUpdate(workdata);
} }