We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 65f3c52 commit 415467fCopy full SHA for 415467f
mpush-tools/src/main/java/com/mpush/tools/thread/pool/DefaultExecutorFactory.java
@@ -83,10 +83,11 @@ public Executor get(String name) {
83
break;
84
case EVENT_BUS:
85
config = ThreadPoolConfig
86
- .buildFixed(T_EVENT_BUS,
87
- CC.mp.thread.pool.event_bus.min,
88
- CC.mp.thread.pool.event_bus.queue_size
89
- );
+ .build(T_EVENT_BUS)
+ .setCorePoolSize(CC.mp.thread.pool.event_bus.min)
+ .setMaxPoolSize(CC.mp.thread.pool.event_bus.max)
+ .setKeepAliveSeconds(TimeUnit.SECONDS.toSeconds(10))
90
+ .setQueueCapacity(CC.mp.thread.pool.event_bus.queue_size);
91
92
case MQ:
93
0 commit comments