| | |
| | | for (int i = 0; i < maxthreadNum; i++) { |
| | | final int index = i; |
| | | final AccountBean accountBean = accountBeanList.get(i); |
| | | executor.execute(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | //业务处理 |
| | | System.out.println("当前线程:" + Thread.currentThread().getName() + " " + index); |
| | | System.out.println("当前处理对象:" + JSON.toJSONString(accountBean)); |
| | | asyncUserGo(accountBean); |
| | | } |
| | | executor.execute(() -> { |
| | | //业务处理 |
| | | System.out.println("当前线程:" + Thread.currentThread().getName() + " " + index); |
| | | System.out.println("当前处理对象:" + JSON.toJSONString(accountBean)); |
| | | asyncUserGo(accountBean); |
| | | }); |
| | | |
| | | }; |
| | | } |
| | | // 关闭线程池 |
| | | executor.shutdown(); |
| | | |
| | | ret.put("code", 1000); |
| | | ret.put("msg", "成功"); |