Java线程池 是如何诞生的？
发布时间：2023-02-03 11:03:24 所属栏目：Linux 来源：
导读： 时间回到2003年，那时我还是一个名不见经传的程序员，但是上级却非常看好我，他们把整个并发模块，都交给了我一个人开发。（难道不是因为经费不足？）
这个星期，我必须要完成并发模块中非常重要的一个功
这个星期，我必须要完成并发模块中非常重要的一个功
|
时间回到2003年，那时我还是一个名不见经传的程序员，但是上级却非常看好我，他们把整个并发模块，都交给了我一个人开发。（难道不是因为经费不足？） 这个星期，我必须要完成并发模块中非常重要的一个功能——线程池。 为什么要使用线程池 作为一个合格的程序员，接到需求，首先我得问自己一句： 为什么要做这个需求？为什么需要线程池？ 就像十多年后，另一个菜鸟在他的博客中说的那样： 软件中的“池”，可以理解为计划经济时代的工厂。 首先，作为工厂，你要管理好你生产的东西，老王从你工厂这里拿走了一把斧头，改天他不需要了，还回来，你可以把这把斧头借给老赵； 其次，你又不能无限制的生产，毕竟在资源极度匮乏的时代，如果都被你拿去生产了，其他要用到资源的地方怎么办？ 总结成两点，“池”的作用： 数据库连接池是这样，线程池也是如此。 你一个任务过来了，我发现池子里有没事干并且还活着的线程，来，拿去用，我也不用费事给你创建一条线程了，要知道线程的创建和销毁可都是麻烦事； 你一个任务过来了，我发现池子的线程都在忙，并且现在池子的线程已经太多了，再不限制下去就要内存溢出了，来，排队去~ 线程池需要考虑哪些问题 简单的架构固然容易实现，但是却不能解决复杂的问题； 而复杂的架构可以解决复杂的问题线程池linux，却没那么好实现。 在介绍线程池原理之前，先来大致看看我设计的线程池ThreadPoolExecutor长什么样子： 线程池linux_线程池中的某个线程执行结束_线程池与线程 图片来源 你们可以先看看这张图，想想图中的各个节点都是什么，为什么需要它们？ 好，现在开始聊聊实现一个线程池，都需要考虑哪些问题。 1、 任务队列 如果每个任务过来，都直接交给线程去执行，那其实算不上解耦。 更好的方法是先把任务放到队列里面，然后当线程空闲的时候，去队列里面取任务过来处理。 为了取的时候可以形成阻塞，我选择了使用阻塞队列BlockingQueue，来保存这些未被处理的任务。 如果你们用过RabbitMQ、Kafka之类的消息中间件，就会发现他们的原理和阻塞队列类似。 2、任务队列的类型 阻塞队列有很多种： 这么多种队列，都有各自的优劣，所以，把任务队列参数，放在构造函数里头，提供给使用线程池的人去设置，是最好不过的了。 3、线程的数量 我定义了两个线程数的变量，一个是核心线程数corePoolSize，另一个是最大线程数maximumPoolSize。这两个参数的差别，可以这样来解释： 同样的，这两个参数也应该放在构造函数，由使用者根据实际情况，来决定要使用多大容量的线程池。 4、Keep-alive times 从厨房拿出来的桌子，在高峰期过后，就要渐渐撤回了吧？同样，当我发现线程池中线程的数量超过corePoolSize，就会去监控线程，发现某条线程很久没有工作了，就把它关掉，这里的很久是多久，那就要看你传过来的keepAliveTime是多少了。 如果你想对corePoolSize线程也做这种监控，只需要调用threadPoolExecutor.allowCoreThreadTimeOut(true)就可以了。 你也许好奇我是怎样判断线程有多久没有活动了，是不是以为我会启动一个监控线程，专门监控哪个线程正在偷懒？ 想太多，其实我只是在线程从工作队列poll任务时，加上了超时限制，如果线程在keepAliveTime的时间内poll不到任务，那我就认为这条线程没事做，可以干掉了，看看这个代码片段你就清楚了， ThreadPoolExecutor getTask(): private Runnable getTask() { boolean timedOut = false; for (;;) { ... try { Runnable r = timed ? workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) : workQueue.take(); if (r != null) return r; timedOut = true; } catch (InterruptedException retry) { timedOut = false; } } } 5、拒绝策略 如果线程池已经被shutdown了，或者线程池中使用的是有界队列，而这个队列已经满了，并且线程数已经达到最大线程数，无法再创建新的线程处理请求，这时候要怎么处理新来的任务？ 在和大家一起讨论之后，我们认为至少有这四种策略： 说到策略，你们或许以为我会用策略模式。 这下你们猜对了，我用的就是策略模式，这个模式是如此简单，以至于我只需要定义一个策略接口， RejectedExecutionHandler： public interface RejectedExecutionHandler { void rejectedExecution(Runnable r, ThreadPoolExecutor executor); } 然后写对应的实现类，实现上面提到的那四种策略，比如DiscardPolicy，直接丢弃，那就是什么都不做呗， DiscardPolicy： public static class DiscardPolicy implements RejectedExecutionHandler { public DiscardPolicy() { } public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { } } 接着在构造函数里，让你们给我传入你们想要使用的策略，最后在我的拒绝任务reject()方法里，调用你们传过来的策略就ok了， final void reject(Runnable command) { handler.rejectedExecution(command, this); } 为什么使用final？那当然是不想让你们重写啦，这个方法木有定制的必要嘛。 至于这个reject方法，是在哪里调用的，你们使用idea，alt + f7就知道了，然后你们会看到我写的很多深奥的代码，那些我今天不就不详细讲解了，今天重点讲解构造函数里的几个参数的作用，也就是你们可以定制的几个参数。 给你们造好的轮子 为了方便你们使用，我已经在Executors里面写了几个线程池的工厂方法，这样，很多新手就不需要了解太多关于ThreadPoolExecutor的知识了，他们只需要直接使用我的工厂方法，就可以使用线程池： 1、newFixedThreadPool 如果你想对线程池里的线程总数做一个限制，那么通过Executors.newFixedThreadPool(…)获取一个固定线程数的线程池，是一个很不错的选择，它将返回一个corePoolSize和maximumPoolSize相等的线程池， Executors newFixedThreadPool： public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); } 2、newCachedThreadPool 如果你希望有一个非常弹性的线程池，那可以使用newCachedThreadPool： public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); } 从上面的工厂方法，可以看出，CachedThreadPool是一个这样配置的ThreadPoolExecutor： 就像不同CPU、显卡的组合的电脑有不同的用途一样（数据分析、打游戏、视频处理等），不同配置的ThreadPoolExecutor也会产生不同的威力，CachedThreadPool的这些配置产生的威力在于： 当然，CachedThreadPool会有一个很明显的隐患，那就是线程数量不可控，当然，你已经弄懂了ThreadPoolExecutor几个重要参数，你完全可以自己定制一个有线程数量上限的CachedThreadPool，或者在创建完CachedThreadPool后，使用setMaximumPoolSize方法修改最大线程数量。 3、newSingleThreadExecutor 触类旁通，很容易理解，这里就不贴源码和解释了。 4、 newScheduledThreadPool 触类旁通，理解起来有些许难度，这里就不贴源码和解释了。 总结 本文围绕ThreadPoolExecutor的构造函数，重点讲解了ThreadPoolExecutor中，几个可以给外部定制的参数的意义和实现原理，希望能对你理解线程池并定制自己的线程池有所帮助。当然，线程池内部还有很多复杂的机制，比如各种状态的管理等等，不过这些都不是外部可以定制的了，后面我们再来讨论。 后记 时钟来到了24点，我跑完了所有ThreadPoolExecutor的测试用例，绿条，全部通过。 正准备提交代码，回家睡觉，突然发现还没给这个类写上自己的大名，于是，啪啪啪，我在类的头上，留下了我的名字...... （编辑：财气旺网 - 财气网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
站长推荐