public void ThreadDemo() {
	//集合  相当于请求内容
	List<String> list = new ArrayList<String>();
	list.add("110101198001119833");
	list.add("110101198001119876");
	list.add("110101198001119892");
	list.add("110101198001119913");
	list.add("110101198001119956");
	//创建线程池 newFixedThreadPool(10) 创建一个定长线程池,可控制线程最大并发数为10(根据需求自行修改)
	ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(10);
	for (String key : list) {
		newFixedThreadPool.execute(new Runnable() {
			@Override
			public void run() {
				//请求体(根据业务需求写)
				BrokerReq brokerReq=new BrokerReq();
				brokerReq.setCertiCode(key);
				//第三方API接口(本场景为外调接口,根据公司框架和业务自行修改)
				Object res = serviceInvoker.httpPostInvokeLoadBalanced("http://app/xxx/xxx",brokerReq, Map.class);
				//以下内容为返回的结果集  请根据返回的信息解析 (内容仅供参考)
				JSONObject jsonObject = JSONObject.parseObject(JSONObject.toJSONString(res));
				String code = jsonObject.getString("code");
				if (!"SYS_S_000".equals(code)) {
					logger.info("调用接口失败");
				}else {
					JSONObject output = jsonObject.getJSONObject("output");
					logger.info("调用接口成功【】",JSON.toJSONString(output));
				}
			}
		});
		
	}
}

参考文档:

https://www.cnblogs.com/baizhanshi/p/5469948.html

Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐