为啥不能使用Exectors创建线程池？还有如何自定义线程名称

素颜马尾好姑娘i 2022-03-10 06:46 127阅读 0赞

转自[https://blog.csdn.net/ken1583096683/article/details/86537966][https_blog.csdn.net_ken1583096683_article_details_86537966]

总结得很到位：首先Excutors会很耗系统资源，线程最大值比较大，或者堆积的请求队列对系统的系统资源的消耗，容易出现OOM

那么如何创建呢？使用ThreadPoolExecutor

我直接介绍里面比较熟悉的写法：

基于jdk1.8

/*ExecutorService pool = new ThreadPoolExecutor(5, 200,
                    0L, TimeUnit.MILLISECONDS,
                    new LinkedBlockingQueue<Runnable>(1024), Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());*/
            ExecutorService pool = new ThreadPoolExecutor(5, 200,
                    0L, TimeUnit.MILLISECONDS,
                    new LinkedBlockingQueue<Runnable>(1024), new MyThreadFactory.DefaultThreadFactory("大鸡腿"), new ThreadPoolExecutor.AbortPolicy());
            pool.execute(()-> System.out.println(Thread.currentThread().getName()));
            pool.shutdown();//gracefully shutdown

这是我见过比较好的改写版本，从第一个的Exectors.defaultThreadFactory()它会自动给线程附上名字，那么我们重写它的方法，如下面：也是实现ThreadFactory类，加入我们自定义的名称，重写namePrefix。

package com.example.demo;
    
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.atomic.AtomicInteger;
    
    public class MyThreadFactory {
        static class DefaultThreadFactory implements ThreadFactory {
            private static final AtomicInteger poolNumber = new AtomicInteger(1);
            private final ThreadGroup group;
            private final AtomicInteger threadNumber = new AtomicInteger(1);
            private final String namePrefix;
    
            DefaultThreadFactory(String name) {
                if(name!=null) {
                    //自定义名称
                    SecurityManager s = System.getSecurityManager();
                    group = (s != null) ? s.getThreadGroup() :
                            Thread.currentThread().getThreadGroup();
                    name="-"+name+"-";
                    namePrefix = name +
                            poolNumber.getAndIncrement() +
                            "-thread-";
                }else {
                    SecurityManager s = System.getSecurityManager();
                    group = (s != null) ? s.getThreadGroup() :
                            Thread.currentThread().getThreadGroup();
                    namePrefix = "-pool-" +
                            poolNumber.getAndIncrement() +
                            "-thread-";
                }
            }
    
            public Thread newThread(Runnable r) {
                Thread t = new Thread(group, r,
                        namePrefix + threadNumber.getAndIncrement(),
                        0);
                if (t.isDaemon())
                    t.setDaemon(false);
                if (t.getPriority() != Thread.NORM_PRIORITY)
                    t.setPriority(Thread.NORM_PRIORITY);
                return t;
            }
        }
    }

执行结果：-大鸡腿-1-thread-1

[https_blog.csdn.net_ken1583096683_article_details_86537966]: https://blog.csdn.net/ken1583096683/article/details/86537966