Java线程池隔离原理

/**
 * 线程池隔离原理：
 * 1、创建多个线程池-ExecutorService-ES实例
 *    1.1 针对不同类型的任务(IO密集型任务和cpu密集型任务)，分别创建多个线程池ES实例;
 *    1.2 每个ES实例都具有独立的的线程数、队列大小、线程工厂等属性资源，以支持不同类型任务的执行
 *        这里是通过Executors.newFixedThreadPool方法，其内部是new ThreadPoolExecutor来设置不同的线程数、队列大小、线程池工厂等属性，以满足不同类型任务的执行需求
 *    1.3 使用适当的线程工厂：为避免线程之间的类加载器干扰，选择合适线程工厂来创建线程;
 *        1) 此处为每个ES实例设置不同的线程工厂，这样就可以为不同的ES实例绑定不同的ClassLoader,从而避免线程之间的类加载器干扰;
 *        3) 线程间的类加载干扰：当多个线程同时执行时，可能会共享类A，在某些情况下可能会导致类A加载错误、类型转换异常等问题;
 *        eg:线程A使用系统ClassLoader加载了一个类，而线程B使用自定义ClassLoader重新加载该类，就可能导致类加载失败或者类型转换异常.
 * 2、提交任务到不同的ExecutorService实例
 *    2.1 使用submit()或execute()方法将不同类型的任务提交到相应的ES实例中进行处理。
 *    2.2 最终通过使用不同的ES实例，实现隔离不同类型的任务，避免相互之间的影响和干扰；
 */
public class ThreadPoolIsolation {
    // 创建IO密集型任务专用的线程池
    private static ExecutorService ioThreadPool = Executors.newCachedThreadPool(new ThreadFactory() {
        @Override
        public Thread newThread(Runnable r) {
            Thread t = new Thread(r);
            t.setDaemon(true);  // 设置为守护线程
            return t;
        }
    });

    // 创建计算密集型任务专用的线程池
    private static ExecutorService cpuThreadPool = Executors.newFixedThreadPool(4, new ThreadFactory() {
        @Override
        public Thread newThread(Runnable r) {
            Thread t = new Thread(r);
            t.setPriority(Thread.MAX_PRIORITY);  // 设置为最高优先级
            return t;
        }
    });

    // 提交IO密集型任务到线程池中执行
    public static void submitIOJob(Runnable job) {
        ioThreadPool.submit(job);
    }

    // 提交计算密集型任务到线程池中执行
    public static void submitCPUJob(Runnable job) {
        cpuThreadPool.submit(job);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45