Spring-boot @Async не работает с @Scheduled

Я использовал это руководство и это проект github в качестве основы для этого SSCCE.

По неизвестной причине методы, помеченные как @Async, запускались из метода @Scheduled, всегда выполняются синхронно.

Я ищу исправление или обходной путь, чтобы код из performTask() работал асинхронно.

Классы ниже:

Приложение.java

@SpringBootApplication
@EnableScheduling
@EnableAsync
public class Application implements AsyncConfigurer{

    public static void main(String[] args) throws Exception {
        SpringApplication.run(Application.class);
    }

    @Override
    @Bean(name="asyncExecutor")
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor exec = new ThreadPoolTaskExecutor();
        exec.setMaxPoolSize(Runtime.getRuntime().availableProcessors()*2);
        exec.setThreadGroupName("MyCustomExecutor");
        exec.setWaitForTasksToCompleteOnShutdown(true);
        exec.setBeanName("asyncExecutor");
        exec.initialize();
        return exec;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new SimpleAsyncUncaughtExceptionHandler();
    }
}

MyAsyncService.java

@Service
public class MyAsyncService {

    static AtomicInteger taskNoCounter = new AtomicInteger();

    public MyAsyncService() {
    }

    @Async("asyncExecutor")
    public void performTask() {
        int delayMs = (int) (System.currentTimeMillis()%1000+1000);
        int taskNo = taskNoCounter.incrementAndGet();
        String taskInfo = "MyAsyncTask [taskNo=" + taskNo + ", delayMs=" + delayMs + ", threadId="+Thread.currentThread().getId()+"]";
        System.out.println("+ start " +taskInfo);
        try {
            Thread.sleep(delayMs);
        } catch (InterruptedException e) {
            // empty on purpose
        }
        System.out.println("- end   " +taskInfo);
    }

}

Запланированные задачи.java

@Component
public class ScheduledTasks {

    @Autowired
    MyAsyncService service;

    @Scheduled(fixedRate = 1000)
    public void reportCurrentTime() {
        for (int i=0; i<20; i++) {
            service.performTask();
        }

    }
}

Получите следующий синхронный результат:

+ start MyAsyncTask [taskNo=1, delayMs=1874, threadId=16]
- end   MyAsyncTask [taskNo=1, delayMs=1874, threadId=16]
+ start MyAsyncTask [taskNo=2, delayMs=1749, threadId=16]
- end   MyAsyncTask [taskNo=2, delayMs=1749, threadId=16]
+ start MyAsyncTask [taskNo=3, delayMs=1498, threadId=16]
- end   MyAsyncTask [taskNo=3, delayMs=1498, threadId=16]
+ start MyAsyncTask [taskNo=4, delayMs=1997, threadId=16]
- end   MyAsyncTask [taskNo=4, delayMs=1997, threadId=16]
+ start MyAsyncTask [taskNo=5, delayMs=1994, threadId=16]

spring-boot java spring spring-async spring-scheduled
person Dariusz    schedule 04.02.2016    source источник
comment
См. stackoverflow.com/questions/24759170/< /а> .   -  person M. Deinum    schedule 04.02.2016
comment
Это оно! Увеличение corePoolSize сработало. Пожалуйста, опубликуйте это как ответ, и я с радостью приму его.   -  person Dariusz    schedule 04.02.2016
comment
Он либо увеличивает CorePoolSize, либо уменьшает размер очереди, так что он фактически достигает максимального количества потоков, когда очередь заполнена. По умолчанию существует очень большая очередь (Integer.MAX_VALUE).   -  person M. Deinum    schedule 04.02.2016

Ответы (1)


arrow_upward
0
arrow_downward

Проблема заключалась не в установке свойства corePoolSize для ThreadPoolTaskExecutor.

По умолчанию corePoolSize равно 1, и количество потоков увеличивается только при заполнении очереди. Поскольку моя очередь была бесконечной, никаких дополнительных потоков в пуле никогда не создавалось.

В итоге я сделал:

exec.setCorePoolSize(Runtime.getRuntime().availableProcessors()+1);
person Dariusz    schedule 24.02.2016