parent
11272f6158
commit
49943af416
|
@ -18,10 +18,10 @@ import java.util.concurrent.ThreadPoolExecutor;
|
||||||
public class ThreadPoolConfig
|
public class ThreadPoolConfig
|
||||||
{
|
{
|
||||||
// 核心线程池大小
|
// 核心线程池大小
|
||||||
private int corePoolSize = 10;
|
private int corePoolSize = 15;
|
||||||
|
|
||||||
// 最大可创建的线程数
|
// 最大可创建的线程数
|
||||||
private int maxPoolSize = 20;
|
private int maxPoolSize = 30;
|
||||||
|
|
||||||
// 队列最大长度
|
// 队列最大长度
|
||||||
private int queueCapacity = 500;
|
private int queueCapacity = 500;
|
||||||
|
|
|
@ -275,14 +275,13 @@ public class MeituanServiceImpl implements IMeituanService {
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public String orderInfoList() {
|
public String orderInfoList() {
|
||||||
LocalDateTime now = LocalDateTime.now();
|
LocalDateTime now = LocalDateTime.now();
|
||||||
BusStoreInfo busStoreInfo = new BusStoreInfo();
|
BusStoreInfo busStoreInfo = new BusStoreInfo();
|
||||||
busStoreInfo.setReturnVisitStatus("1");
|
busStoreInfo.setReturnVisitStatus("1");
|
||||||
List<BusStoreInfo> busStoreInfoList = busStoreInfoMapper.selectBusStoreInfoList(busStoreInfo);
|
List<BusStoreInfo> busStoreInfoList = busStoreInfoMapper.selectBusStoreInfoList(busStoreInfo);
|
||||||
long startTime = System.currentTimeMillis(); // 开始时间
|
long startTime = System.currentTimeMillis(); // 开始时间
|
||||||
List<List<BusStoreInfo>> list1= SplitListUtils.pagingList(busStoreInfoList,4); //拆分集合
|
List<List<BusStoreInfo>> list1= SplitListUtils.pagingList(busStoreInfoList,30); //拆分集合
|
||||||
CountDownLatch countDownLatch = new CountDownLatch(list1.size());
|
CountDownLatch countDownLatch = new CountDownLatch(list1.size());
|
||||||
for (List<BusStoreInfo> list2 : list1) {
|
for (List<BusStoreInfo> list2 : list1) {
|
||||||
asyncTask.executeAsync(list2,busStoreInfoMapper,countDownLatch);
|
asyncTask.executeAsync(list2,busStoreInfoMapper,countDownLatch);
|
||||||
|
@ -1124,6 +1123,27 @@ public class MeituanServiceImpl implements IMeituanService {
|
||||||
.setDefaultRequestConfig(config)
|
.setDefaultRequestConfig(config)
|
||||||
.setDefaultCredentialsProvider(credsProvider)
|
.setDefaultCredentialsProvider(credsProvider)
|
||||||
.build();
|
.build();
|
||||||
|
// CloseableHttpClient httpClient = HttpClients.custom().setDefaultRequestConfig(config).build();
|
||||||
|
return httpClient;
|
||||||
|
}
|
||||||
|
|
||||||
|
private CloseableHttpClient localHttpClient() {
|
||||||
|
// JDK 8u111版本后,目标页面为HTTPS协议,启用proxy用户密码鉴权
|
||||||
|
System.setProperty("jdk.http.auth.tunneling.disabledSchemes", "");
|
||||||
|
// String proxyHost = proxyProperties.getProxyAddr();
|
||||||
|
// int proxyPort = proxyProperties.getProxyPort();
|
||||||
|
// String username = proxyProperties.getAccount();
|
||||||
|
// String password = proxyProperties.getPwd();
|
||||||
|
// HttpHost proxy = new HttpHost(proxyHost, proxyPort);
|
||||||
|
// CredentialsProvider credsProvider = new BasicCredentialsProvider();
|
||||||
|
// credsProvider.setCredentials(new AuthScope(proxyHost, proxyPort),
|
||||||
|
// new UsernamePasswordCredentials(username, password));
|
||||||
|
// RequestConfig config = RequestConfig.custom().setProxy(proxy).build();
|
||||||
|
CloseableHttpClient httpClient = HttpClients
|
||||||
|
.custom()
|
||||||
|
// .setDefaultRequestConfig(config)
|
||||||
|
// .setDefaultCredentialsProvider(credsProvider)
|
||||||
|
.build();
|
||||||
// CloseableHttpClient httpClient = HttpClients.custom().setDefaultRequestConfig(config).build();
|
// CloseableHttpClient httpClient = HttpClients.custom().setDefaultRequestConfig(config).build();
|
||||||
return httpClient;
|
return httpClient;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue