栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

java多线程处理数据

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

java多线程处理数据

要查询的数据量过多时,分多个线程查询,查完合并,提高效率

 static class ThredQuery implements Callable {

    private List parms;
    private Object object;

    public ThredQuery(List parms) {
      this.parms = parms;
    }

    @Override
    public Object call() {
      // 查询数据库
      System.out.println("查询条件:--->" + parms);
      // 模拟查询出的数据
      // 处理的业务
      object = "ID:" + parms + "查询的数据";
      return object;
    }
  }


  public static void main(String[] args) throws InterruptedException, ExecutionException {
    //返回结果
    List result = new ArrayList<>();

    //模拟需要查询的ID
    List ids = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);


    // 要开的线程数量
    int threadNum = 5;
    // 拆分查的idlist
    List> smallerLists = Lists.partition(ids, 2);

    //分配任务
    List>> tasks = new ArrayList<>();
    for (int i = 0; i < threadNum; i++) {
      ThredQuery thredQuery = new ThredQuery(smallerLists.get(i));
      tasks.add(thredQuery);
    }
    //执行
    ExecutorService executorService = Executors.newFixedThreadPool(threadNum);
    List>> futures = executorService.invokeAll(tasks);
    if (futures.size() > 0) {
      for (Future> future : futures) {
        result.add(future.get());
      }
    }
    System.out.println("查询出的数据:" + result.size());
    for (Object o : result) {
      System.out.println(o.toString());
    }
    executorService.shutdown();
  }


转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号