前言:我们在开发过程中,有时会遇到一个方法内
去循环执行某个任务,而每次循环执行的这个任务会耗时很大,如果循环次数又比较多的话,那么总体下来这个方式执行的时间会很长。如何解决这个问题,可以在很快的时间内完成这个方法?这个时候就要用到线程池了,使用线程池异步执行任务。目前使用线程池java提供了两种方式:
从字面意思看,是多个线程,也就是可以创建多个线程
使用方式如下:
MultiFutureThread multiFutureThread = new MultiFutureThread(taskList.size(), 10);
taskList.forEach(task->{
multiFutureThread.setCallable(()->{
//处理任务的代码
....
....
return null;
});
});
multiFutureThread.exec();
注意: 这里的taskList是需要处理的任务集合,创建MultiFutureThread对象的第一个参数是taskList.size()也就是要处理的任务的数量,第二个参数是需要创建的线程数10个,当任务数大于线程数时,任务会等待排队… 所有任务处理完毕,一定要需要 multiFutureThread.exec()手动关闭线程,以免造成OOM,浪费资源!
直接创建一个线程池
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();
注:这种创建线程池的方式和第一种异曲同工罢了,最后一定要记得关闭线程池,不然麻烦就大了!
以上就是在方法中使用多线程处理任务的方式哦!