private List<String> getUpdateDataList(List<String> phoneList) {

// 创建线程池,这里创建了20个

ExecutorService executorService = Executors.newFixedThreadPool(20);

// 保存任务的返回结果

List<Future<String>> futureList = new ArrayList<>();

// 分配任务

for (String loopStr : phoneList) {

// 启动多线程返回号码的城市，有返回值使用submit()，并且多线程实现callable接口

Future<String> future = executorService

.submit(new UpdateCityThreadJob<String>(loopStr));

futureList.add(future);

}

// 关闭线程池

executorService.shutdown();

// 保存城市

List<String> collection = new ArrayList<>();

// 取出任务中的参数

for (Future<String> future : futureList) {

try {

// 取出任务中的结果

String city = future.get();

collection.add(city);

} catch (Exception e) {

throw new AppException(HttpStatus.INTERNAL_SERVER_ERROR);

}

}

return collection;

}

public class UpdateCityThreadJob<V> implements Callable<String> {

        // 电话号码

private String phoneNumber;

public UpdateCityThreadJob(String phoneNumber) {

this.phoneNumber = phoneNumber;

}

/**

* @param phoneNumber 电话号码

* @return 城市

* @Description 获取 电话号码归属地邮政信息

*/

private String getCityRepeat(String phoneNumber) {

String city = "";

try {

city = getCity(phoneNumber);

} catch (Exception e) {

// 请求失败，重试五次，（防止网络原因导致请求失败）

for (int i = 0; i < 5; i++) {

try {

city = getCity(phoneNumber);

} catch (Exception e1) {

continue;

}

}

}

return city;

}

/**

* 

* @Description 获取城市

* @param phoneNumber 电话号码

* @return 城市

* @throws Exception

*/

private String getCity(String phoneNumber) throws Exception {

// 请求第三方接口判断号码归属地

String result = HttpClient

.doGet("http://apis.juhe.cn/mobile/get?phone=" + phoneNumber + "&dtype=xml&key=" + Constants.API_KEY);

return result;

}

@Override

public String call() throws Exception {

synchronized (phoneNumber) {

// 获取城市

String city = getCityRepeat(phoneNumber);

return city;

}

}

}