标签:nose service 线程池 cached 导致 临时工 single read repo
1.为什么不使用Executors提供4个线程池创建线程池
阿里巴巴开放手册这样写:
4. 【强制】线程池不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式,这样 的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险。 说明:Executors 返回的线程池对象的弊端如下:
1)FixedThreadPool 和 SingleThreadPool: 允许的请求队列长度为 Integer.MAX_VALUE,可能会堆积大量的请求,从而导致 OOM。
2)CachedThreadPool 和 ScheduledThreadPool: 允许的创建线程数量为 Integer.MAX_VALUE,可能会创建大量的线程,从而导致 OOM。
2.创建过程
虽然不建议使用Executors创建线程池,但是还是要搞清楚他的原理。
public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); }
public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>())); }
注意:
1.核心线程池=最大线程池(不聘请临时工)
2.LinkedBlockingQueue按照先进先出队列,最大队列为Integer.MAX_VALUE
public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); }
注意:
1.没有核心线程池,只有最大线程池(全部聘请临时工干活,干完活就全部辞退,不地道)
2.最大线程池Integer.MAX_VALUE
3.SynchronousQueue是这样一种阻塞队列,其中每个 put 必须等待一个 take,即如果有两个线程等待take,队列可以存两个,如果没有等待take,队列不能存入。
public ScheduledThreadPoolExecutor(int corePoolSize) { super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS, new DelayedWorkQueue()); }
注意:
1.最大线程池Integer.MAX_VALUE
2.这个线程池还不太理解,延后
标签:nose service 线程池 cached 导致 临时工 single read repo
原文地址:https://www.cnblogs.com/SmilingEye/p/11751302.html