【开发规约】并发-自定义线程及线程池ThreadFactory，方便出错回溯

短命女 2021-06-11 15:14 373阅读 0赞

最近没事看了下 阿里的开发手册，有些东西我觉得还是有必要遵守或者知晓的，

在代码里有多线程或者并发处理的情况下，万一出现了线上问题或者Bug，日志中默认看到的打印日志，都显示的是

“pool-1-thread-1”，“pool-1-thread-2” 这种的，很不容易发现问题，无法定位。

所以在项目中，创建线程的地方推荐使用自定义的线程工厂ThreadFactory来进行创建，指定当时Thread的创建环境和名字，便于后续查找及发现问题。

同时在线程池的使用方面，尽量避免使用JUC自带的Executors来进行线程池的创建，如果了解的话，应该知道

Fixed、Single的线程池中的 blockingQueue 阻塞队列都是无限长度的，可能会堆积大量请求

同样，Cache和Schedule类型的线程池的 Max线程数，是Integer.Max，这样会造成大量线程的创建，

这两种情况都会带来不必要的对象消耗，最终极有可能变成OOM。

推荐做法是 使用 ThreadPoolExecutor 自定义线程池的 各个参数，选择更贴合具体业务场景的配置参数，达到更好的性能。

package thread;
    
    import org.jetbrains.annotations.NotNull;
    
    import java.util.concurrent.*;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.stream.Stream;
    
    public class ThreadFactoryMain implements ThreadFactory{
    
        private final String groupName;
        private AtomicInteger nextId = new AtomicInteger(1);
    
        public ThreadFactoryMain(String groupName) {
            this.groupName = "ThreadFactoryMain -" + groupName + "-worker-";
        }
    
        @Override
        public Thread newThread(@NotNull Runnable r) {
            String threadName = groupName + nextId.incrementAndGet();
            Thread thread = new Thread(null,r,threadName,0);
            return thread;
        }
    
        public static void main(String[] args){
            ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10,50,
                    60L, TimeUnit.SECONDS,
                    new LinkedBlockingQueue<Runnable>(20),
                    new ThreadFactoryMain("zs.zhou"));
            Stream.iterate(0,n->n+1).limit(10).forEach(i->threadPoolExecutor.submit(new Runnable() {
                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName() + " ::: --- " + i);
                }
            }));
            System.out.println("end");
            threadPoolExecutor.shutdown();
        }
    }

输出：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o2OTE4Mzc4Nw_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3o2OTE4Mzc4Nw_size_16_color_FFFFFF_t_70]: /images/20210527/af80cd20f75f4fff92a86175869a0a87.png