代码bug

[QAQ516284797]

@Override
public List<Point> recordHandlePoints(List<ImportDataStep> steps) {

    System.out.println("多线程查询======== start");

    List<Point> points = new ArrayList<>();
    for (ImportDataStep step : steps) {
        Future<List<Point>> future = executorService.submit(new HighImportDataPointFuture(step, pointLogic));
        try {
            points.addAll(future.get());
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }

    System.out.println("多线程查询======== point " + points.size() + " 条数==============");
    return points;
}

位于 HighImportDataServiceImpl 实现错误了吧，future.get()会阻塞线程 所以实际上是串行提交，没有线程并行
future.get()应该在任务提交之外的循环遍历获取吧

[QAQ516284797]

@Override
public List<Point> recordHandlePoints(List<ImportDataStep> steps) {

    System.out.println("多线程查询======== start");

    List<Point> points = new ArrayList<>();
    LinkedList<Future<List<Point>>> tasks=new LinkedList<>();
    for (ImportDataStep step : steps) {
        tasks.add(executorService.submit(new HighImportDataPointFuture(step, pointLogic)));

    }
    while (!tasks.isEmpty()){
        try {
            points.addAll(tasks.pollFirst().get());
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }

    System.out.println("多线程查询======== point " + points.size() + " 条数==============");
    return points;
}

建议修改代码

[liujiawinds]

future替换成completablefuture之后,改使用allof才是正解.