parent
e5ec38074b
commit
46c40b4ddc
|
|
@ -70,7 +70,7 @@ class TaskExecutorConfigurations {
|
||||||
static class ThreadPoolTaskExecutorBuilderConfiguration {
|
static class ThreadPoolTaskExecutorBuilderConfiguration {
|
||||||
|
|
||||||
@Bean
|
@Bean
|
||||||
@ConditionalOnMissingBean(ThreadPoolTaskExecutorBuilder.class)
|
@ConditionalOnMissingBean
|
||||||
ThreadPoolTaskExecutorBuilder threadPoolTaskExecutorBuilder(TaskExecutionProperties properties,
|
ThreadPoolTaskExecutorBuilder threadPoolTaskExecutorBuilder(TaskExecutionProperties properties,
|
||||||
ObjectProvider<ThreadPoolTaskExecutorCustomizer> threadPoolTaskExecutorCustomizers,
|
ObjectProvider<ThreadPoolTaskExecutorCustomizer> threadPoolTaskExecutorCustomizers,
|
||||||
ObjectProvider<TaskDecorator> taskDecorator) {
|
ObjectProvider<TaskDecorator> taskDecorator) {
|
||||||
|
|
@ -121,9 +121,7 @@ class TaskExecutorConfigurations {
|
||||||
@ConditionalOnMissingBean
|
@ConditionalOnMissingBean
|
||||||
@ConditionalOnThreading(Threading.VIRTUAL)
|
@ConditionalOnThreading(Threading.VIRTUAL)
|
||||||
SimpleAsyncTaskExecutorBuilder simpleAsyncTaskExecutorBuilderVirtualThreads() {
|
SimpleAsyncTaskExecutorBuilder simpleAsyncTaskExecutorBuilderVirtualThreads() {
|
||||||
SimpleAsyncTaskExecutorBuilder builder = builder();
|
return builder().virtualThreads(true);
|
||||||
builder = builder.virtualThreads(true);
|
|
||||||
return builder;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private SimpleAsyncTaskExecutorBuilder builder() {
|
private SimpleAsyncTaskExecutorBuilder builder() {
|
||||||
|
|
|
||||||
|
|
@ -65,7 +65,7 @@ class TaskSchedulingConfigurations {
|
||||||
static class ThreadPoolTaskSchedulerBuilderConfiguration {
|
static class ThreadPoolTaskSchedulerBuilderConfiguration {
|
||||||
|
|
||||||
@Bean
|
@Bean
|
||||||
@ConditionalOnMissingBean(ThreadPoolTaskSchedulerBuilder.class)
|
@ConditionalOnMissingBean
|
||||||
ThreadPoolTaskSchedulerBuilder threadPoolTaskSchedulerBuilder(TaskSchedulingProperties properties,
|
ThreadPoolTaskSchedulerBuilder threadPoolTaskSchedulerBuilder(TaskSchedulingProperties properties,
|
||||||
ObjectProvider<ThreadPoolTaskSchedulerCustomizer> threadPoolTaskSchedulerCustomizers) {
|
ObjectProvider<ThreadPoolTaskSchedulerCustomizer> threadPoolTaskSchedulerCustomizers) {
|
||||||
TaskSchedulingProperties.Shutdown shutdown = properties.getShutdown();
|
TaskSchedulingProperties.Shutdown shutdown = properties.getShutdown();
|
||||||
|
|
@ -104,9 +104,7 @@ class TaskSchedulingConfigurations {
|
||||||
@ConditionalOnMissingBean
|
@ConditionalOnMissingBean
|
||||||
@ConditionalOnThreading(Threading.VIRTUAL)
|
@ConditionalOnThreading(Threading.VIRTUAL)
|
||||||
SimpleAsyncTaskSchedulerBuilder simpleAsyncTaskSchedulerBuilderVirtualThreads() {
|
SimpleAsyncTaskSchedulerBuilder simpleAsyncTaskSchedulerBuilderVirtualThreads() {
|
||||||
SimpleAsyncTaskSchedulerBuilder builder = builder();
|
return builder().virtualThreads(true);
|
||||||
builder = builder.virtualThreads(true);
|
|
||||||
return builder;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private SimpleAsyncTaskSchedulerBuilder builder() {
|
private SimpleAsyncTaskSchedulerBuilder builder() {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue