java.util.concurrent和工具类的简单介绍与分析

一、java.util.concurrent体系的主要大板块包含内容

说到JUC其实就是说java的多线程等和锁及一些状态转换，中断等，它还涉及到一些tools工具的东东，见下图：

Tools也包含了5个部分的知识：Executors、Semaphor、Exchanger、CyclicBarrier、CountDownLatch，其实也就是五个工具类

二、Executors

它主要用来创建线程池，代理了线程池的创建，使得你的创建入口参数变得简单，通过方法名便知道了你要创建的线程池是什么样一个线程池，功能大概是什么样的，其实线程池内部都是统一的方法来实现，通过构造方法重载，使得实现不同的功能，但是往往这种方式很多时候不知道具体入口参数的改变有什么意思，除非读了源码才知道，此时builder模式的方式来完成，builder什么样的东西它告诉你就可以。

常见的方法有(都是静态方法)：

1、创建一个指定大小的线程池，如果超过大小，放入blocken队列中，默认是LinkedBlockingQueue，默认的ThreadFactory为：Executors.defaultThreadFactory()，是一个Executors的一个内部类。

Executors.newFixedThreadPool(int)

内部实现如下：

public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); }

2、创建一个指定大小的线程池，如果超过大小，放入blocken队列中,默认是LinkedBlockingQueue，自己指定ThreadFactory，自己写的ThreadFactory，必须implements ThreadFactory，实现方法：newThread(Runnable)。

Executors.newFixedThreadPool(int,ThreadFactory)

内部实现是：

public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(), threadFactory); }

3、创建线程池长度为1的，也就是只有一个长度的线程池，多余的必须等待，它和调用Executors.newFixedThreadPool(1)得到的结果一样：

Executors.newSingleThreadExecutor()

内部实现是：

public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>())); }

4、和方法3类似，可以自定义ThreadFactory，这里就不多说了！

5、创建可以进行缓存的线程池，默认缓存60s，数据会放在一个SynchronousQueue上，而不会进入blocken队列中，也就是只要有线程进来就直接进入调度，这个不推荐使用，因为容易出问题，除非用来模拟一些并发的测试：

Executors.newCachedThreadPool();

内部实现为：

public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); }

6、和方法5类似，增加自定义ThreadFactory

7、添加一个Schedule的调度器的线程池，默认只有一个调度：

Executors.newSingleThreadScheduledExecutor();

内部实现为(这里可以看到不是用ThreadPoolExector了，schedule换了一个类，内部实现通过ScheduledThreadPoolExecutor类里面的内部类ScheduledFutureTask来实现的，这个内部类是private，默认引用不到

public static ScheduledExecutorService newSingleThreadScheduledExecutor() { return new DelegatedScheduledExecutorService (new ScheduledThreadPoolExecutor(1)); }

8、和7一样，增加自己定义的ThreadFactory

9、添加一个schedule的线程池调度器，和newFixedThreadPool有点类似：

Executors.newScheduledThreadPool();

内部代码为：

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) { return new ScheduledThreadPoolExecutor(corePoolSize); }

其实内部Exectors里面还有一些其他的方法，我们就不多说明了，另外通过这里，大家先可以了解一个大概，知道Exectors其实是一个工具类，提供一系列的静态方法，来完成对对应线程池的形象化创建。

每日更新分享java培训开发技术知识，记得关注我哦！

 

标签：java,Executors,ThreadFactory,return,util,concurrent,线程,new,public
来源： https://www.cnblogs.com/xiaobaizaixianzhong/p/15043067.html