多任务共用一个大的线程池还是每个任务单独使用线程池？

野性酷女 2024-03-26 22:03 123阅读 0赞

### 1. 大线程池与多线程池 ###

开发过程中的任务大致分为两大类：

*  IO密集型任务，此类任务特点就是需要经常暂停任务进行其他的IO操作，如文件读写、网络数据请求等。
 *  计算密集型任务，此类任务的特点就是大多数操作都是在内存中进行。

下面通过模拟这两种情况来看一下结果，首先看一下在大线程池和多线程池执行IO密集型任务所消耗的时间：

package org.example.objectsize;
    
    import java.io.File;
    import java.io.IOException;
    import java.nio.charset.StandardCharsets;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.atomic.AtomicInteger;
    import org.apache.commons.io.FileUtils;
    
    public class IOTest {
    
        public static void main(String[] args) throws Exception{
            extracted();
            main1(args);
        }
    
        private static void extracted() throws InterruptedException {
            final AtomicInteger integer = new AtomicInteger();
            final  File file = new File("C:\\Users\\mxsm\\Desktop\\RocketMQ5\\aaa.txt");
            ExecutorService executorService = Executors.newFixedThreadPool(50);
            CountDownLatch latch =  new CountDownLatch(50);
            long l = System.currentTimeMillis();
            for(int i = 0; i < 50; ++i){
                executorService.execute(new Runnable() {
                    @Override
                    public void run() {
                        do{
                            try {
                                FileUtils.write(file, integer.get()+"", StandardCharsets.UTF_8);
                            } catch (IOException e) {
                                e.printStackTrace();
                            }
                        }while (integer.getAndIncrement() < 100000);
                        latch.countDown();
                    }
                });
            }
            latch.await();
            System.out.println("大线程池："+(System.currentTimeMillis()-l));
            executorService.shutdown();
        }
        public static void main1(String[] args) throws Exception{
            final AtomicInteger integer = new AtomicInteger();
            final  File file = new File("C:\\Users\\mxsm\\Desktop\\RocketMQ5\\aaa.txt");
            Exec