ThreadPoolTaskScheduler не работает с пулом потоков - PullRequest
Новая
       11

ThreadPoolTaskScheduler не работает с пулом потоков

0 голосов
/ 04 сентября 2018

создаю 

@Bean
ThreadPoolTaskScheduler taskScheduler(){
    ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
    threadPoolTaskScheduler.setPoolSize(5);
    threadPoolTaskScheduler.setAwaitTerminationSeconds(1);
    threadPoolTaskScheduler.setThreadNamePrefix("Test-");
    threadPoolTaskScheduler.initialize();
    return threadPoolTaskScheduler;
}

И в моем компоненте я использую его: 

@PostConstruct
    public void test() {
        taskScheduler.scheduleWithFixedDelay(() -> {
            try {
                Thread.sleep(9000L);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            log.info("test");
        }, 1000L);
    }

Я жду, что каждую 1 секунду будет запускаться один поток из PoolSize(5), а через 5 таймов пул будет заполняться, и я буду ждать первого свободного потока, и он продолжит работу.

Но на самом деле я вижу следующее: 

2018-09-04 18:06:42.769  INFO 10128 --- [main] c.e.scheduling.SchedulingApplication : Started SchedulingApplication in 1.69 seconds (JVM running for 2.193)
2018-09-04 18:06:51.385  INFO 10128 --- [Test-1] com.example.scheduling.MyScheduler : test
2018-09-04 18:07:01.387  INFO 10128 --- [Test-1] com.example.scheduling.MyScheduler : test
2018-09-04 18:07:11.389  INFO 10128 --- [Test-2] com.example.scheduling.MyScheduler : test

Тест печати одной нити каждые 9 секунд

EDIT

Я проверял

scheduleAtFixedRate - результат тот же

EDIT2 

@PostConstruct
public void test() {
    taskScheduler.scheduleAtFixedRate(this::test2, 1000L);
}

@Async
public void test2() {
    try {
        Thread.sleep(9000L);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    log.info("test");
}

@EnableAsync
@EnableScheduling
@Configuration
public class JavaConfig {

Не помогло: 

2018-09-05 10:31:40.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:31:49.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:31:58.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:32:07.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:32:16.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:32:25.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:32:34.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:32:43.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:32:52.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:33:01.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:33:10.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test
2018-09-05 10:33:19.160  INFO 13636 --- [         Test-3] com.example.scheduling.MyScheduler       : test

Ответы [ 2 ]

0 голосов
/ 05 сентября 2018

Благодаря подсказкам @Sun я нашел решение: 

@PostConstruct
public void test() {
    taskScheduler.scheduleAtFixedRate(testBean::test, 1000L);
}

и переместить метод в другой класс, потому что я использую proxy по умолчанию: 

@Slf4j
@Component
public class TestBean {

    @Async
    public void test(){
        try {
            Thread.sleep(9000L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        log.info("hz");
    }
}

И поместите @EnableAsync в мой класс конфигурации

0 голосов
/ 04 сентября 2018

Вам нужно сделать это Async, если вы хотите выполнить задачу, даже если она запущена, например: 

@PostConstruct
public void test() {
    taskScheduler.scheduleAtFixedRate(this::makeLog, 1000);
}

@Async
public void makeLog() {
    try {
        Thread.sleep(9000L);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    log.info("test");
}
...