zoukankan      html  css  js  c++  java
  • 多线程并发问题解决

    有这样一个需求:查询数据库里的多张表的数据量,并按从大到小的顺序排序。

    首先想到的就是按传统的做法,去循环查询每一张表的数据量,再放到一个集合进行排序。

    这样也能实现,但是查询速度太慢,如果有上百张表,且每张表都是上百万条数据量的,

    这样时间需要非常久,这个时候就要用到多线程了,充分调动CPU的资源。

     1     //创建线程池
     2     ExecutorService exe = Executors.newCachedThreadPool();
     3     //创建任务数组
     4     CompletableFuture[] list1 = new CompletableFuture[securityDictionaryFroms.size()];
     5     //循环创建任务并把任务加到任务数组
     6     for (int i = 0; i < securityDictionaryFroms.size(); i++) {
     7         SecurityDictionaryFrom securityDictionaryFrom = securityDictionaryFroms.get(i);
     8         //创建任务实现类实例
     9         CountTask countTask = new CountTask(securityDictionaryFrom.getDicValue(), getJdbcTemplate());
    10         //定义任务执行完成后需要进行的后续操作
    11         CompletableFuture completableFuture = CompletableFuture.supplyAsync(countTask, exe).whenComplete((result, e) -> {
    12             Temp temp = new Temp();
    13             temp.setTableNameCn(securityDictionaryFrom.getDicName());
    14             temp.setTableNameEn(securityDictionaryFrom.getDicValue());
    15             temp.setDataSum(result);
    16             list.add(temp);
    17         }).exceptionally((e) -> {
    18             e.printStackTrace();
    19             return 0;
    20         });
    21         //将任务加入任务数组
    22         list1[i] = completableFuture;
    23     }
    24     //将任务数组交给一个任务来调度
    25     CompletableFuture<Void> all = CompletableFuture.allOf(list1).thenApply(x -> {
    26         log.info("all");
    27         return null;
    28     });
    29     //阻塞直至所有任务都执行完成
    30     Void aVoid = all.get();
    31     //关闭线程池
    32     exe.shutdown();
    33     list2 = list;
    34     //对查询结果进行排序
    35     list2 = list2.stream().sorted(Comparator.comparing(Temp::getDataSum).reversed()).collect(Collectors.toList());
  • 相关阅读:
    C++ new 解析重载 .
    __cdecl,__fastcall, __stdcall 什么区别? .
    C++构造函数调用顺序
    用gdb调试core dump文件
    placement new(转)
    [精华] 跟我一起写 Makefile
    使用 GDB 调试多进程程序
    第37条:避免对函数中继承得来的默认参数值进行重定义
    程序只运行一个是实例 .
    南通SEO:单页的SEO元素
  • 原文地址:https://www.cnblogs.com/zhncnblogs/p/14818775.html
Copyright © 2011-2022 走看看