一、配置jdbc.properties添加:
#------------ Task ------------task.core_pool_size=5task.max_pool_size=50task.queue_capacity=1000task.keep_alive_seconds=60
二、配置Spring的applicationContext.xml添加:
<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <!-- 核心線程數(shù) --> <property name="corePoolSize" value="${task.core_pool_size}" /> <!-- 最大線程數(shù) --> <property name="maxPoolSize" value="${task.max_pool_size}" /> <!-- 隊(duì)列最大長度 --> <property name="queueCapacity" value="${task.queue_capacity}" /> <!-- 線程池維護(hù)線程所允許的空閑時間,默認(rèn)為60s --> <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" /> </bean> <!-- 注解式 --> <task:annotation-driven />
三、在實(shí)現(xiàn)層Impl聲明并注入:
@Resource(name = "taskExecutor") private TaskExecutor taskExecutor;
四、在方法里調(diào)用:
try { taskExecutor.execute(new Runnable() { public void run() { //這里編寫處理業(yè)務(wù)代碼 } }); } catch (Exception e) { e.printStackTrace(); }
|
新聞熱點(diǎn)
疑難解答
圖片精選