| | |
|---|
| | | String apiUrl = ""; |
|---|
| | | ResponseEntity<String> responseEntity = null; |
|---|
| | | JSONObject reqJson = JSONObject.parseObject(pd.getReqData()); |
|---|
| | | apiUrl = "feeApi/listAllRoomOweFees" + mapToUrlParam(reqJson); |
|---|
| | | apiUrl = "/feeApi/listAllRoomOweFees" + mapToUrlParam(reqJson); |
|---|
| | | responseEntity = this.callCenterService(restTemplate, pd, "", apiUrl, HttpMethod.GET); |
|---|
| | | |
|---|
| | | if (responseEntity.getStatusCode() != HttpStatus.OK) { //跳过 保存单元信息 |
|---|
| | |
|---|
| | | this.restTemplate = restTemplate; |
|---|
| | | } |
|---|
| | | |
|---|
| | | public static void main(String[] args) { |
|---|
| | | Java110ThreadPoolFactory<String> pool = Java110ThreadPoolFactory.getInstance().createThreadPool(20); |
|---|
| | | for (int i = 21; i > 0; i--) { |
|---|
| | | Integer data = i; |
|---|
| | | pool.submit(() -> { |
|---|
| | | //这个地方可以写一个函数，参数可以从外层传入 |
|---|
| | | System.out.println("网络操作开始" + data); |
|---|
| | | Thread.sleep(data * 1000); |
|---|
| | | System.out.println("网络操作结束" + data); |
|---|
| | | return data + ""; |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | List<String> users = pool.get(); |
|---|
| | | for (String u : users) { |
|---|
| | | System.out.println(u); |
|---|
| | | } |
|---|
| | | pool.stop(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
