java多线程实战1:方法内部使用多线程的两种方式

发布时间:2023年12月22日

前言:我们在开发过程中,有时会遇到一个方法内
去循环执行某个任务,而每次循环执行的这个任务会耗时很大,如果循环次数又比较多的话,那么总体下来这个方式执行的时间会很长。如何解决这个问题,可以在很快的时间内完成这个方法?这个时候就要用到线程池了,使用线程池异步执行任务。目前使用线程池java提供了两种方式:

1、MultiFutureThread

从字面意思看,是多个线程,也就是可以创建多个线程
使用方式如下

 MultiFutureThread multiFutureThread = new MultiFutureThread(taskList.size(), 10);
  taskList.forEach(task->{
  					multiFutureThread.setCallable(()->{
                     //处理任务的代码
                     ....
                     ....
                      return null;
       });
});
 multiFutureThread.exec();

注意: 这里的taskList是需要处理的任务集合,创建MultiFutureThread对象的第一个参数是taskList.size()也就是要处理的任务的数量,第二个参数是需要创建的线程数10个,当任务数大于线程数时,任务会等待排队… 所有任务处理完毕,一定要需要 multiFutureThread.exec()手动关闭线程,以免造成OOM,浪费资源!

2、Executors.newFixedThreadPool

直接创建一个线程池

ExecutorService executorService = Executors.newFixedThreadPool(10);
 CountDownLatch countDownLatch = new CountDownLatch(taskList.size());
  taskList.forEach(task->{
  		   executorService.submit(() -> {
                  //处理任务的代码
                     ....
                     ....
                    countDownLatch.countDown();
                });
});
 // 等待所有线程执行完成
            try {
                countDownLatch.await();
            } catch (InterruptedException e) {
                log.debug("线程异常:" + e.getMessage());
            }
            // 线程池关闭
            executorService.shutdown();

:这种创建线程池的方式和第一种异曲同工罢了,最后一定要记得关闭线程池,不然麻烦就大了!
以上就是在方法中使用多线程处理任务的方式哦!

文章来源:https://blog.csdn.net/qq_43380361/article/details/135147721
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。