扫码关注官方订阅号
人生最曼妙的风景,竟是内心的淡定与从容!
其实如果你是因为每个查询任务都比较慢,所以想采用这种方式,不如去优化一下sql。或者你可以用下面的这种线程池的方式来处理,不过代码的复杂度会大大提高的。Futrue返回的包装的数据类型对应你sql返回的类型或者你可以使用fork/join来处理
public class CallableAndFuture { public static void main(String[] args) { ExecutorService threadPool = Executors.newSingleThreadExecutor(); List<Future<Integer>> futures = new ArrayList<>(); for (int i = 10; i < 15; i++) { futures.add(threadPool.submit(new Task(i))); } try { Thread.sleep(1000);// 可能做一些事情 int allSum = 0; for (Future<Integer> f : futures) { int fsum = f.get(); System.out.println("sum:" + fsum); allSum += fsum; } System.out.println("allSum:" + allSum); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } threadPool.shutdown(); } } class Task implements Callable<Integer> { private int i; public Task(int i) { this.i = i; } @Override public Integer call() throws Exception { // 替换成db的查询 int sum = 0; for (int j = 0; j <= i; j++) { sum += j; } return sum; } }
微信扫码关注PHP中文网服务号
QQ扫码加入技术交流群
扫描下载App
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
PHP学习
技术支持
返回顶部
其实如果你是因为每个查询任务都比较慢,所以想采用这种方式,不如去优化一下sql。或者你可以用下面的这种线程池的方式来处理,不过代码的复杂度会大大提高的。
Futrue返回的包装的数据类型对应你sql返回的类型
或者你可以使用fork/join来处理