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

前言：我们在开发过程中，有时会遇到一个方法内
去循环执行某个任务，而每次循环执行的这个任务会耗时很大，如果循环次数又比较多的话，那么总体下来这个方式执行的时间会很长。如何解决这个问题，可以在很快的时间内完成这个方法？这个时候就要用到线程池了，使用线程池异步执行任务。目前使用线程池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();

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