原理:开启线程,并实现Callable接口
一、线程池
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
/**
* 线程池
*
* @author ht
*
*/
public class ThreadPoolEx {
public static ThreadPoolExecutor tPool = (ThreadPoolExecutor) Executors.newFixedThreadPool(3);
/**
* 初始化线程池
*
*/
public ThreadPoolEx() {
}
public static ThreadPoolExecutor getInstance() {
if (tPool == null) {
tPool = (ThreadPoolExecutor) Executors.newCachedThreadPool();
}
return tPool;
}
}
二、代码执行
private ThreadPoolExecutor pool = ThreadPoolEx.getInstance();
/**
* 循环--拉取并存库
* @param totalPages
* @param startDate
* @param endDate
*/
private void getRequestPriceChange(Integer totalPages, String startDate, String endDate){
List<Future<List<T>>> futureList = new ArrayList<>();
for (int currentPageIndex = 2; currentPageIndex <= totalPages; currentPageIndex++) {
PullChangePriceTask priceTask = new PullChangePriceTask(pool, this, startDate, endDate, currentPageIndex);
Future<List<T>> roomPriceInfoFuture = pool.submit(priceTask);
futureList.add(roomPriceInfoFuture);
}
List<T> rateChangeInfos = new ArrayList<>();
for (Future<List<T>> ctripResponseFuture : futureList) {
List<T> rateChangeInfo = null;
try {
rateChangeInfo = ctripResponseFuture.get();
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
rateChangeInfos.addAll(rateChangeInfo);
}
}
三、线程
import com.ctrip.entity.response.hotel.pice.change.RateChangeInfo;
import com.ctrip.spring.utils.exception.MsgException;
import com.ctrip.web.manage.controller.hotel.PriceController;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ThreadPoolExecutor;
/**
* @Author: Jr
* @Description:
* @Date:Createc in 上午11:34 2018/11/27
* @Modified By:
*/
public class PullChangePriceTask implements Callable<List<RateChangeInfo>> {
ThreadPoolExecutor taskExecutor;
private PriceController priceController;
private String startDate;
private String endDate;
private int currentPageIndex;
public PullChangePriceTask(ThreadPoolExecutor taskExecutor, PriceController priceController, String startDate, String endDate, int currentPageIndex) {
this.taskExecutor = taskExecutor;
this.priceController = priceController;
this.startDate = startDate;
this.endDate = endDate;
this.currentPageIndex = currentPageIndex;
}
@Override
public List<RateChangeInfo> call() {
return priceController.pullChangePriceAndSave(startDate,endDate,currentPageIndex);
}
}
网友评论