一、在sPRing配置文件中配置
<!-- 異步線程池 --> <bean id="threadPool" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <!-- 核心線程數(shù) --> <property name="corePoolSize" value="3" /> <!-- 最大線程數(shù) --> <property name="maxPoolSize" value="20" /> <!-- 隊列最大長度 >=mainExecutor.maxSize --> <property name="queueCapacity" value="1000" /> <!-- 線程池維護(hù)線程所允許的空閑時間 --> <property name="keepAliveSeconds" value="300" /> <!-- 線程池對拒絕任務(wù)(無線程可用)的處理策略 --> <property name="rejectedExecutionHandler"> <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" /> </property> </bean>二、在service類中注入 @Autowired private ThreadPoolTaskExecutor threadPool;
三、service方法中使用
public void doSomething(){ threadPool.execute(new Runnable() { @Override public void run() { //異步執(zhí)行耗時的業(yè)務(wù)任務(wù) } });}完成
備注：如果要想得到耗時任務(wù)的返回結(jié)果可以如下使用：
String resp="";Future<String> task = threadPool.submit(new Callable<String>(){ @Override public String call() throws Exception { String callbackResp = HttpUtils.post(Url, params, "utf-8"); return callbackResp; } }); try { //注意task.get()會阻塞，直到返回數(shù)據(jù)為止，所以一般這樣用法很少用 resp=task.get(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); }新聞熱點
疑難解答
