parent
e657e609bd
commit
3d56c0fc63
3 changed files with 19 additions and 2 deletions
|
|
@ -10,7 +10,7 @@ import ru.spcex.platform.imdg.api.ImdgProvider;
|
||||||
import ru.spcex.platform.imdg.iml.hazelcast.service.HazelcastService;
|
import ru.spcex.platform.imdg.iml.hazelcast.service.HazelcastService;
|
||||||
|
|
||||||
@Configuration
|
@Configuration
|
||||||
public class SchedulerServiceImdgConfig {
|
public class ImdgConfig {
|
||||||
private static ThreadPoolTaskExecutor createThreadPoolTaskExecutor(int maxPoolSz, boolean waitForCompletion) {
|
private static ThreadPoolTaskExecutor createThreadPoolTaskExecutor(int maxPoolSz, boolean waitForCompletion) {
|
||||||
ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor();
|
ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor();
|
||||||
if (maxPoolSz > 2) {
|
if (maxPoolSz > 2) {
|
||||||
|
|
@ -0,0 +1,17 @@
|
||||||
|
package ru.spcex.clearing.scheduler.config;
|
||||||
|
|
||||||
|
import org.springframework.context.annotation.Bean;
|
||||||
|
import org.springframework.context.annotation.Configuration;
|
||||||
|
import org.springframework.scheduling.TaskScheduler;
|
||||||
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
|
||||||
|
|
||||||
|
@Configuration
|
||||||
|
public class SchedulerServiceConfig {
|
||||||
|
@Bean(name = "taskScheduler")
|
||||||
|
public TaskScheduler taskScheduler() {
|
||||||
|
ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
|
||||||
|
threadPoolTaskScheduler.setPoolSize(5);
|
||||||
|
threadPoolTaskScheduler.setThreadNamePrefix("ThreadPoolTaskScheduler");
|
||||||
|
return threadPoolTaskScheduler;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -48,7 +48,7 @@ public class TaskManager implements InitializingBean, AutoCloseable {
|
||||||
private final ExecutorService outputExecutor;
|
private final ExecutorService outputExecutor;
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
TaskManager(TaskScheduler taskScheduler,
|
TaskManager(@Qualifier("taskScheduler") TaskScheduler taskScheduler,
|
||||||
ImdgProvider imdgProvider,
|
ImdgProvider imdgProvider,
|
||||||
LauncherSender launcherSender,
|
LauncherSender launcherSender,
|
||||||
@Qualifier("plannerQueue") BlockingQueue<Map.Entry<Process, PlannerAllToday>> plannerQueue) {
|
@Qualifier("plannerQueue") BlockingQueue<Map.Entry<Process, PlannerAllToday>> plannerQueue) {
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue