Commit 697dece3 by huangfusuper

修改扫描线程为线程池运行

parent 41b9e7a7
...@@ -25,11 +25,12 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH ...@@ -25,11 +25,12 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH
/** /**
* 扫描线程数量 * 扫描线程数量
*/ */
public static ThreadPoolExecutor SCAN_WORLD_THREAD = ThreadPoolUtil.createFixedLengthThreadPoolExecutor("scan flow stream thread",THREAD_RUN_OPT.entrySet().size()); public static ThreadPoolExecutor SCAN_WORLD_THREAD = null;
@Override @Override
public void runDaemonThreads() { public void runDaemonThreads() {
Set<Map.Entry<String, BaseThreadRunHelper>> entries = THREAD_RUN_OPT.entrySet(); Set<Map.Entry<String, BaseThreadRunHelper>> entries = THREAD_RUN_OPT.entrySet();
SCAN_WORLD_THREAD = ThreadPoolUtil.createFixedLengthThreadPoolExecutor("scan flow stream thread",entries.size());
entries.forEach(threadExamples ->{ entries.forEach(threadExamples ->{
String examplesKey = threadExamples.getKey(); String examplesKey = threadExamples.getKey();
BaseThreadRunHelper examplesValue = threadExamples.getValue(); BaseThreadRunHelper examplesValue = threadExamples.getValue();
...@@ -67,8 +68,8 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH ...@@ -67,8 +68,8 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH
dateAligned(sleepTime,threadName); dateAligned(sleepTime,threadName);
} }
}); });
//exampleThread.setName(threadName); exampleThread.setName(threadName);
//exampleThread.setDaemon(true); exampleThread.setDaemon(true);
SCAN_WORLD_THREAD.execute(exampleThread); SCAN_WORLD_THREAD.execute(exampleThread);
//exampleThread.start() //exampleThread.start()
THREADS_MAP.put(threadName,exampleThread); THREADS_MAP.put(threadName,exampleThread);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment