线程池不关闭引发的OOM血案

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

@Override
public Integer getPermissionCount(Long AppId) {
    ExecutorService es = Executors.newFixedThreadPool(4);
    CompletionService<Integer> cs = new ExecutorCompletionService<>(es);
    cs.submit(() -> flagService.getFlagCount(appId));
    cs.submit(() -> roleService.getRoleCountByAppId(appId));
    cs.submit(() -> featureService.getFeatureCountByAppId(appId));
    cs.submit(() -> areaService.getAreaCountByAppId(appId));

    Integer result = 0;
    for (int i=0; i<4; i++) {
        try {
            Integer permissionCount = cs.take().get();
            result = result + permissionCount;
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
    return result;
}

1

es.shutdown();