xieb
2023-09-05 c3c1256c1eef28e257213b746b9f1c3d239cdb91
蓝证用户推送接收接口
1 files modified
18 ■■■■■ changed files
skjcmanager/skjcmanager-service/skjcmanager-user/src/main/java/cn/gistack/system/user/sync/controller/UserPushController.java 18 ●●●●● patch | view | raw | blame | history
skjcmanager/skjcmanager-service/skjcmanager-user/src/main/java/cn/gistack/system/user/sync/controller/UserPushController.java
@@ -82,17 +82,15 @@
        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", "成功");