你到时候在这个地方打个断点，然后 Debug 看一眼，就非常明确了：
关于框起来的这部分的几个关键参数，我解释一下：
首先是 count 参数，就是我们定义的 3。那么 range(0,3)，就是 0,1,2。
然后是 supplier，这玩意就是前面我们说的 executor 方法返回的 supplier 接口，可以看到里面封装的就是个线程池。
接着是里面有一个非常关键的操作 ：map(ValueRef::new)。
这个操作里面的 ValueRef 对象，很关键：
com.github.phantomthief.pool.impl.KeyAffinityImpl.ValueRef
关键的地方就是这个对象里面的 concurrency 变量。
还记得最前面说的“挑选最闲置的执行器(线程池)”这句话吗？
怎么判断是否闲置？
靠的就是 concurrency 变量。
其对应的代码在这：
com.github.phantomthief.pool.impl.KeyAffinityImpl#select
能走到断点的地方，说明当前这个 key 是之前没有被映射过的，所以需要为其指定一个线程池。
而指定这个线程池的操作，就是循环这个 all 集合，集合里面装的就是 ValueRef 对象：
所以，comparingInt(ValueRef::concurrency) 方法就是在选当前所有的线程池，并发度最小的一个。
如果这个线程池从来没有用过或者目前没有任务在使用，那么并发度必然是 0 ，所有会被选出来。
如果所有线程池正在被使用，就会选 concurrency 这个值最低的线程池。
我这里只是给大家说一个大概的思路，如果要深入了解的话，自己去翻源码去。
如果你非常了解 lambdas 的用法的话，你会觉得写的真的很优雅，看起来很舒服。
如果你不了解 lambdas 的话...
那你还不赶紧去学？
另外我还发现了两个熟悉的东西。
朋友们，请看这是什么：
这难道不就是线程池参数的动态调整吗？
第二个是这样的：
RabbitMQ 里面的动态调整我也写过啊，也是强调过这三处地方：
- 增加 {@link #setCapacity(int)} 和 {@link #getCapacity()}
- {@link #capacity} 判断边界从 == 改为 >=
- 部分 signal() 信号触发改为 signalAll()
另外作者还提到了 RabbitMQ 的版本里面会有导致 NPE 的 BUG 的问题。
这个就没细研究了，有兴趣的可以去对比一下代码，就应该能知道问题出在哪里。
说说 Dubbo
为什么要说一下 Dubbo 呢？
因为我似乎在 Dubbo 里面也发现了 KeyAffinityExecutor 的踪迹。
为什么说是似乎呢？
因为最终没有被合并到代码库里面去。
其对应的链接是这里：
这一次提交一共提交了这么多文件：
里面是可以找到我们熟悉的东西：
其实思路都是一样的，但是你会发现即使是思路一样，但是两个不同的人写出来的代码结构还是很不一样的。
Dubbo 这里把代码的层次分的更加明显一点，比如定义了一个抽象的 AbstractKeyAffinity 对象，然后在去实现了随机和最小并发两种方案。
在这些细节处上是有不同的。
但是这个代码的提供者最终没有用这些代码，而是拿出了一个替代方案：
https://github.com/apache/dubbo/pull/8999
在这一次提交里面，他主要提交了这个类：
org.apache.dubbo.common.threadpool.serial.SerializingExecutor
这个类从名字上你就知道了，它强调的是串行化。
带大家看看它的测试用例，你就知道它是怎么用的了：
首先是它的构造方法入参是另外一个线程池。
然后提交任务的时候用 SerializingExecutor 的 execute 方法进行提交。
在任务内部，干的事就是从 map 里面取出 val 对应的 key ，然后进行加 1 操作再放回去。
大家都知道上面的这个操作在多线程的情况是线程不安全的，最终加出来的结果一定是小于循环次数的。
但是，如果是单线程的情况下，那肯定是没问题的。
那么怎么把线程池映射为单线程呢？
SerializingExecutor 干得就是这事。
而且它的原理特别简单，核心代码就几行。
首先它自己搞了个队列：
提交进来的任务都扔到队列里面去。
接下来再一个个的执行。
怎么保证一个个的执行呢？
方法有很多，它这里是搞了个 AtomicBoolean 对象来控制：
这样就实现了把多线程任务搞成串行化的场景。
只是让我奇怪的是 SerializingExecutor 这个类目前在 Dubbo 里面并没有使用场景。
但是，如果你时候你就要实现这样奇怪的功能，比如别人给你一个线程池，但是到你的流程里面出入某种考虑，需要把任务串行化，这个时候肯定是不能动别人的线程池的，那么你可以想起 Dubbo 这里有一个现成的，比较优雅的、逼格较高的解决方案。
最后说一句
好了，看到了这里了， 转发、在看、点赞随便安排一个吧，要是你都安排上我也不介意。写文章很累的，需要一点正反馈。
给各位读者朋友们磕一个了：
