Spring线程池ThreadPoolTaskExecutor配置详情

<!-- spring thread pool executor -->    <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">  <!-- 线程池维护线程的最少数量 -->  <property name="corePoolSize" value="5" />  <!-- 允许的空闲时间 -->  <property name="keepAliveSeconds" value="200" />  <!-- 线程池维护线程的最大数量 -->  <property name="maxPoolSize" value="10" />  <!-- 缓存队列 -->  <property name="queueCapacity" value="20" />  <!-- 对拒绝task的处理策略 -->  <property name="rejectedExecutionHandler">   <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" />  </property> </bean>

@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(classes = { MultiThreadConfig.class })public class MultiThreadTest { @Autowired private ThreadPoolTaskExecutor taskExecutor; @Autowired private MultiThreadProcessService multiThreadProcessService;  @Test public void test() {  int n = 20;  for (int i = 0; i < n; i++) {   taskExecutor.execute(new MultiThreadDemo(multiThreadProcessService));   System.out.println("int i is " + i + ", now threadpool active threads totalnum is " + taskExecutor.getActiveCount());  }    try {   System.in.read();  } catch (IOException e) {   throw new RuntimeException(e);  } }}

/** * 多线程并发处理demo * @author daniel.zhao * */public class MultiThreadDemo implements Runnable { private MultiThreadProcessService multiThreadProcessService;  public MultiThreadDemo() { }  public MultiThreadDemo(MultiThreadProcessService multiThreadProcessService) {  this.multiThreadProcessService = multiThreadProcessService; }  @Override public void run() {  multiThreadProcessService.processSomething(); }}

@Servicepublic class MultiThreadProcessService { public static final Logger logger = Logger.getLogger(MultiThreadProcessService.class);  /**  * 默认处理流程耗时1000ms  */ public void processSomething() {  logger.debug("MultiThreadProcessService-processSomething" + Thread.currentThread() + "......start");  try {   Thread.sleep(1000);  } catch (InterruptedException e) {   throw new RuntimeException(e);  }  logger.debug("MultiThreadProcessService-processSomething" + Thread.currentThread() + "......end"); }}

 @Configuration @ComponentScan(basePackages = { "com.xxx.multithread" }) @ImportResource(value = { "classpath:config/application-task.xml" }) @EnableScheduling public class MultiThreadConfig { }