IOT/MiddlePlatform
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

#区域连续作业相关

Browse Source
This commit is contained in:
rqian
2026-11-03 16:06:58 +08:00
parent f25a0b5018
commit 99c7a3ab87
24 changed files with 480 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
maibu-common/src/main/java/com/maibu/config/DeviceTask.java
View File

@@ -30,37 +30,37 @@ public class DeviceTask {
private int keepAlive;
/*设备状态池*/
/* 设备状态池 */
@Bean(FastBeeConstant.TASK.DEVICE_STATUS_TASK)
public Executor deviceStatusTaskExecutor() {
return builder(FastBeeConstant.TASK.DEVICE_STATUS_TASK);
}
/*平台自动获取线程池(例如定时获取设备信息)*/
/* 平台自动获取线程池(例如定时获取设备信息) */
@Bean(FastBeeConstant.TASK.DEVICE_FETCH_PROP_TASK)
public Executor deviceFetchTaskExecutor() {
return builder(FastBeeConstant.TASK.DEVICE_FETCH_PROP_TASK);
}
/*设备回调信息(下发指令(服务)设备应答信息)*/
/* 设备回调信息(下发指令(服务)设备应答信息) */
@Bean(FastBeeConstant.TASK.DEVICE_REPLY_MESSAGE_TASK)
public Executor deviceReplyTaskExecutor() {
return builder(FastBeeConstant.TASK.DEVICE_REPLY_MESSAGE_TASK);
}
/*设备主动上报(设备数据有变化主动上报)*/
/* 设备主动上报(设备数据有变化主动上报) */
@Bean(FastBeeConstant.TASK.DEVICE_UP_MESSAGE_TASK)
public Executor deviceUpMessageTaskExecutor() {
return builder(FastBeeConstant.TASK.DEVICE_UP_MESSAGE_TASK);
}
/*指令下发(服务下发)*/
/* 指令下发(服务下发) */
@Bean(FastBeeConstant.TASK.FUNCTION_INVOKE_TASK)
public Executor functionInvokeTaskExecutor() {
return builder(FastBeeConstant.TASK.FUNCTION_INVOKE_TASK);
}
/*内部消费线程*/
/* 内部消费线程 */
@Bean(FastBeeConstant.TASK.MESSAGE_CONSUME_TASK)
public Executor messageConsumeTaskExecutor() {
return builder(FastBeeConstant.TASK.MESSAGE_CONSUME_TASK);
@@ -81,7 +81,7 @@ public class DeviceTask {
return builder(FastBeeConstant.TASK.DELAY_UPGRADE_TASK);
}
/*设备其他消息处理*/
/* 设备其他消息处理 */
@Bean(FastBeeConstant.TASK.DEVICE_OTHER_TASK)
public Executor deviceOtherTaskExecutor() {
return builder(FastBeeConstant.TASK.DEVICE_OTHER_TASK);
@@ -107,6 +107,11 @@ public class DeviceTask {
return builder(FastBeeConstant.TASK.AUTO_RULE);
}
@Bean(FastBeeConstant.TASK.REGION_CONSECUTIVE_TASK)
public Executor regionConsecutiveTask() {
return builder(FastBeeConstant.TASK.REGION_CONSECUTIVE_TASK);
}
@Bean(FastBeeConstant.TASK.MAP_MESSAGE_PUSH)
public Executor mapMessagePush() {
return builder(FastBeeConstant.TASK.MAP_MESSAGE_PUSH);
@@ -122,8 +127,7 @@ public class DeviceTask {
return builder(FastBeeConstant.TASK.COMMON_DEVICE_MONITOR);
}
/*组装线程池*/
/* 组装线程池 */
private ThreadPoolTaskExecutor builder(String threadNamePrefix) {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(coreSize);
@@ -132,7 +136,7 @@ public class DeviceTask {
executor.setQueueCapacity(queueCapacity);
// 线程池对拒绝任务的处理策略
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
//线程池名的前缀
// 线程池名的前缀
executor.setThreadNamePrefix(threadNamePrefix);
executor.initialize();
return executor;