Commit c914a370 authored by lihao's avatar lihao

code review

parent a84189b9
package com.mushiny.task.executor.autoconfig; package com.mushiny.task.executor.autoconfig;
import com.mushiny.task.executor.core.TaskPoolFactory; import com.mushiny.task.executor.core.TaskPoolFactory;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
...@@ -14,17 +12,11 @@ import java.util.concurrent.ThreadPoolExecutor; ...@@ -14,17 +12,11 @@ import java.util.concurrent.ThreadPoolExecutor;
@EnableConfigurationProperties(value = TaskExecutorProperties.class) @EnableConfigurationProperties(value = TaskExecutorProperties.class)
public class TaskExecutorAutoConfiguration { public class TaskExecutorAutoConfiguration {
@Bean("listLoopThreadPool")
@ConditionalOnMissingBean(name = { "listLoopThreadPool" } )
public ThreadPoolExecutor listLoopThreadPool(TaskExecutorProperties taskExecutorProperties) {
TaskPoolConfig pool = taskExecutorProperties.getPool();
return new ThreadPoolExecutor(pool.getCorePoolSize(), pool.getMaximumPoolSize(), pool.getKeepAliveTime(), pool.getTimeUnit(), new LinkedBlockingQueue<>());
}
@Bean @Bean
@ConditionalOnBean(name = { "listLoopThreadPool" }) public TaskPoolFactory taskPoolFactory (TaskExecutorProperties taskExecutorProperties) {
public TaskPoolFactory taskPoolFactory () { TaskPoolConfig pool = taskExecutorProperties.getPool();
return new TaskPoolFactory(); ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(pool.getCorePoolSize(), pool.getMaximumPoolSize(), pool.getKeepAliveTime(), pool.getTimeUnit(), new LinkedBlockingQueue<>());
return new TaskPoolFactory(threadPoolExecutor);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment