如果是IO密集型应用,则线程池大小设置为2N+1;

    如果是CPU密集型应用,则线程池大小设置为N+1;

    N代表CPU的核数。

    假设我的服务器是4核的,且一般进行大数据运算,cpu消耗较大,那么线程池数量设置为5为最优。

    (现在很多项目线程池滥用,注意分配线程数量,建议不要动态创建线程池,尽量将线程池配置固定,这样方便以后整体的把控和后期维护。每个核心业务线程池要互相独立,互不影响。)

    例子(spring):

    1. <bean class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"
    2. id="userPrivacyDataObtainThreadPool">
    3. <!-- 核心线程数 -->
    4. <property value="6" name="corePoolSize"/>
    5. <!-- 最大线程数 -->
    6. <property value="10" name="maxPoolSize"/>
    7. <!-- 队列最大长度 >=mainExecutor.maxSize -->
    8. <property value="200" name="queueCapacity"/>
    9. <!-- 线程池维护线程所允许的空闲时间 -->
    10. <property value="300" name="keepAliveSeconds"/>
    11. <!-- 线程池对拒绝任务(无线程可用)的处理策略 -->
    12. <property name="rejectedExecutionHandler">
    13. <bean class="java.util.concurrent.ThreadPoolExecutor$AbortPolicy"/>
    14. </property>
    15. </bean>

    再附上scheduler定时任务的线程池配置:

    1. <!--项目内定时任务 -->
    2. <bean id="scheduler" class="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler">
    3. <!-- 设置线程池容量,也是最大并发线程数 -->
    4. <property name="poolSize" value="2" />
    5. <!-- 当任务被取消的同时从当前调度器移除 -->
    6. <property name="removeOnCancelPolicy" value="true" />
    7. <!-- 线程名前缀 -->
    8. <property name="threadNamePrefix" value="cashpay-scheduler-" />
    9. <!-- 设置线程池中任务的等待时间,如果超过这个时候还没有销毁就强制销毁 -->
    10. <property name="awaitTerminationSeconds" value="60" />
    11. <!-- 当调度器shutdown被调用时等待当前被调度的任务完成 -->
    12. <property name="waitForTasksToCompleteOnShutdown" value="true" />
    13. <!-- 线程池对拒绝任务(无线程可用)的处理策略 -->
    14. <property name="rejectedExecutionHandler">
    15. <bean class="java.util.concurrent.ThreadPoolExecutor$AbortPolicy"/>
    16. </property>
    17. </bean>