SPRING中的线程池ThreadPoolTaskExecutor

一、初始化

1，直接调用

ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();
//线程池所使用的缓冲队列
poolTaskExecutor.setQueueCapacity(200);
//线程池维护线程的最少数量
poolTaskExecutor.setCorePoolSize(5);
//线程池维护线程的最大数量
poolTaskExecutor.setMaxPoolSize(1000);
//线程池维护线程所允许的空闲时间
poolTaskExecutor.setKeepAliveSeconds(30000);
poolTaskExecutor.initialize();

2、配置文件

<!-- 配置线程池 -->
<bean id ="taskExecutor"  class ="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor" >
    <!-- 线程池维护线程的最少数量 -->
<span style="white-space:pre">  </span><property name ="corePoolSize" value ="5" />
    <!-- 线程池维护线程所允许的空闲时间 -->
<span style="white-space:pre">  </span><property name ="keepAliveSeconds" value ="30000" />
    <!-- 线程池维护线程的最大数量 -->
<span style="white-space:pre">  </span><property name ="maxPoolSize" value ="1000" />
    <!-- 线程池所使用的缓冲队列 -->
<span style="white-space:pre">  </span><property name ="queueCapacity" value ="200" />
</bean>

程序里面获取：

ApplicationContext ctx =  new ClassPathXmlApplicationContext("applicationContext.xml");
ThreadPoolTaskExecutor poolTaskExecutor = (ThreadPoolTaskExecutor)ctx.getBean("taskExecutor");


二、利用线程池启动线程
Thread udpThread = new Thread(udp);
poolTaskExecutor.execute(udpThread);
获取当前线程池活动的线程数：
int count = poolTaskExecutor.getActiveCount();
logger.debug("[x] - now threadpool active threads totalNum : " +count);