线程池任务怎么终止和撤回

ok， 紧接着呢，咱们来看这样一道面试题，来自于阿里的啊，现成池使用完毕，为何必须执行沙荡方法？那当然也可以执行沙荡闹方法。呃，他对标的薪资呢，一般在二十到三十 k 左右，岗位呢，也是中高级开发工程师。 那首先这个问题咱们要清楚，如果我在使用完毕线程值之后，没有及时的去调用砂档或者砂档闹方法，会造成什么问题？ 那咱们都清楚啊，县城时在帮咱们去处理任务的时候呢，他的内部会帮咱们启动一个县城，而启动县城的方式咱们可以看之前看过的 add worker 方法， 在 a d d work 方法中咱们可以看到，哎，其实他的工作线程也是基于死锐的对象 去执行了一个 star 的方法，然后呢，这种线程它本身就会占用一个训练基站，而这种训练基站的话呢，要清楚啊，他在咱们的 j m 层面中属于 j c 弱者， 那根据咱们的可达性分析算法，这个线程他就不可能被回收，他会一直占用着咱们的 j v m 内存的资源， 那这样的话就会造成一个问题，你没有及时的执行沙荡和沙荡荡。 ok， 我构建的所有县城，只要是核心的，他永远都不会被回收，那这样的话就会造成一个内存泄露问题。 好，除了咱们现成的内存泄露之外呢，还有另外一个问题，什么呢？一定要注意啊，这里在现成池中启动工作，现成时是基于你 work 对象内部的 死锐的去启动的，而当我执行 t 点 star 之后，它会执行我 worker 对象当中的乱方法， 而在 run 方法中会执行 run worker， 而在 run worker 内部传入了 this， 而这个 this 属于我当前的 worker 对象，那么这样的话就可以理解为我启动的线程还指向着我的 worker 对象，我的 worker 对象也是不能被回收的。同时 worker 对象属于现成池的内部类，你内部类都没有被回收的话，你的外部类也没有办法被回收，就会造成我的整个现成池对象也不会被回收。 所以说最终啊，咱们可以确定一点，如果说你没有在使用完 b 现成池之后及时的调用砂当或者砂当当方法的话呢，很有 可能造成你的整个县城池对象都没有办法被这些回收，从而占用咱们的堆内增资源很严重。那如果说这种县，这种县，这种县城池啊，你这个一直都没有去执行杀到，那最终肯定会造成一个内存泄露的问题， 那解决这个问题的方式也很简单，看题目就知道了，只要执行杀到或者杀到闹方法就可以了。那这个方这个问题是怎么去解决的？其实呢，前面已经把他的核心点说出来了， 就是你的核心线程没有被回收掉吗？那当咱们去执行沙特当方法的时候，可以看到他做了两点很重要的事情，第一点，他把现成时的状态从软拧改为了沙特当，而当这个位置改为沙当之后呢， 咱们所有阻塞的工作线程在前面会有一个判断，而这个判断呢，通过刹道就可以直接跳出获取任务的过程了，也就是咱们的核心线程在执行完毕一个任务之后，要通过这个 get task 方法，尝试从阻塞对列中拉取任务。 而在拉取任务的时候呢，这边可以看到，如果是非核心， ok， 我走他的处方法，只要阻塞一段时间没有任务，我就直接结束掉当前线程。 但如果是核心县城，我会执行 take 方法，而这个 take 方法呢，永远都不会被回收，他会一直在这边等着，直到有任务传进来才可以。 而在前面啊，执行到这个方法之前，有一个判断，如果说你现成值的状态已经大于 等于杀当，并且你的阻塞对列当中已经没有任务了，那么我会直接到这 啊，直接结束我的 get 他这个方法。我不会继续往下走，到咱们当前的 take 方法这个位置。所以说，咱们刚才看到的杀他当方法，杀他当， 哎，哎， id 卡住了，好，当咱们执行杀当方法之后，更改了现成池状态变为杀当之后，那么咱们的工作现成就不会再往下走，走到 take 方法了。 哎，但是啊，我有的县城可能已经走到了这个方法，正在阻塞，那怎么办呢？所以说他还有第二个操作，他执行了一个叫做 interrupt workers 的方法。在这个方法内部，他会做一个事情，把所有 的没有正在运行任务的工作线程，直接把他的中段标记位设置为主。 而当中断标记位设置为处之后呢，咱们在 gettask 中，已经执行到 take 方法的线程就会被唤醒了。说白了，我阻塞时会挂起线程，而当线程中断之后，我会被唤醒，那我就会继续向下走，重新循环。走到这个位置之后，你会发现，哎，状态改变了， 状态改变之后，我依然可以通过这个状态的判断退出咱们的 get task 方法，而最终在咱们的 run worker 方法内部就会退出我的 wifi 循环，因为这边反复的是个闹。 退出 vivo 学员之后呢，正常地做一些后续的处理，然后最终返回到我 worker 对象当中的软方法软窝可结束了。软方法结束了，现成自然也就结束了。那同样的，如果你执行了沙特荡闹方法，他会更加彻底。来看一下咱们的沙特荡闹 在杀到闹方法里面呢，同样的，他第一个事情把状态改为 stop， 而这个状态改为 stop， 跟之前的状态改为杀到有异曲同工之妙。都是一样的，县城在执行到库或者是 take 方法之前，先会判断县城值的状态， 只要状态不是 running， 我都会直接结束啊。那么还有另外一个情况，那正在阻测怎么办呢？你会发现它的 interrupt rocks 方法会更加彻底。我不管你的工作现程正在做什么事情，我直接执行这个中断方法，让你的 工作线程直接中断啊，直接中断。除了你工作线程刚刚在创建的时候，我没有办法中断你。但是无论是正在执行任务的，还是准备去组织队列获取任务的，或者是正在组织队列尝试获取任务的线程，我都直接把你中断。那这样一来， 咱们的工作线程就可以以一个比较快的速度去结束掉他的生命周期。那这样一来，工作线程没了 work 对象就没有指向了。 worker 对象没有指向之后， srid pro execute 现成值对象也没有指向了，那这样才可以被 g c 正常的回收。 那这就是咱们关于这个问题，现实为何必须要执行杀到，先阐述清楚不杀到会出现什么问题，其次执行了杀到或者杀到闹之后，他是如何帮我解决这个问题的？

如果你想执行定时或延迟的任务，那么你需要用到该就的 excutt soris 接口中的方法。在了解这些方法之前，我得先介绍该借口的时间内，也就是具备执行定时或延迟任务的线程值。 我们之前创立了健身池都没实现过该接口，所以他们不具备执行定时或延时任务的功能。这个类的名字有点长，叫 sk a 九的所谓的 polo， 一个 stole， 中文翻译过来就是叫 度献真词。什么意思呢？就是具备执行定时或延时任务的献真词，他还可以执行周期性任务。这个下一期再讲他继承字所谓的 polo excut 类，说明他也能干普通献真词干的事。那如何创建他？ 我们可以通过他自身的各个方法来创建他，也可以通过攻击类一个 qq 的词来创建他。一共有四个方法，他们的作用我列举出来了，如图所示， 具体内容就不一一念了。现在来依次介绍我们开团的两个方法。首先是延时执行一次 lower 任务的词叠就有方法。注意他不是重复执行的，时间到了以后他只执行一次。他有三个三处，第一个三处是任务只能 轮船，忘了过任务。第二个参数是指定延迟的时间，这个参数要和第三个参数一起看。第三个参数是指定时间，单位可以是年月日，也可以是十分秒。方法，返回一个四个 a 九的浮游艇对象和浮游艇一样，用来接收任务执行结， 由于 lond 过任务，没有执行结果，所以他就只是起到一个取消任务和查看任务进度的作用。下面动画演示四该九方法的执行过程。 这是一个正在运行的限制迟，这是我们要延时执行的任务，就用 ska， 就有方法提交给现车。迟限制迟开始处理任务，因为是延迟任务，所以 要等到时间到了以后任务才开始执行。任务执行完成以后将结果返回给调研者，调研者拉到结果以后可自行处理。下面编写视力代码，首先定 一个任务 past 实现，忘了管接口，任务内容是输出当前时间，待会看看任务前后的时间间隔等不等于延时时间。接下来我们来执行该任务，首先将任务 创建出来，然后创建一个核心县城数为五的调度县城池，接着在提交任务之前输出一次当前时间，在 接着调用是该组方法，并将任务传递给他，延时时间指定为三秒钟，最后调用下档方法关闭显示池。至此 问方法编写完成，整个例子也编写完成。执行程序观察执行结果。从执行结果来看，程序输出一点九分三十秒和 一点九分三十三秒，他们之间相差正好是三秒钟，说明任务的确是延迟三秒后执行的。接下来来看看延迟执行一次科尔伯任务的该救方法和前面的方法除了提交的任务不同以外，其余的都相同。下面我们就不再重复延迟 执行动画了，直接编写视力代码，重新编写一个有返回值的任务为 wtast， 实现科二播结构。任务内容是以字符串形式返回当前时间，所以科二播的范显示词句重写课方法要用 洛克泰姆的老方法，以自服串的形式返回当前时间。至此，任务部分编写完成执行任务的代码还是应用之前的，只不过需要将他四个任务改为违章的他四个任务。接下来接收该九方法范围之日拿到 到返为止。以后要用 fuqi 等给的方法输出结果这个方法有异常，抛出使用揣盖将其捕获。另外，我们将关闭健身池的操作移到 fant 里代码块中。至此，执行任务的代码改写完成再来执行。陈 去看看。从执行结果来看，程序输出十点零二分三十八秒和十点零二分四十一秒，他们之间相差正好是三秒钟，说明任务的确是延迟三秒后执行的。最后总结一下本节内容，本节介绍了执行定时延迟任务的方法给 他的作用及用法。这里就不太坠数了，在实际开发中，我一般用他们来执行需要延时且只执行一次的任务。这个结的代码我放在了给他号码上，大家如果有需要的话可以前去查看。

今天我要给大家解析一道源自京东一面的面试题如何优雅的终止现成池。接下来我们就开始解析这道面试题。 现成池提供了两个终止现成池的方法下档方法和下档闹方法。下档方法有两点停止现成池，接受新的任务，等待现成池中的所有任务执行完毕。下档闹方法有三点停止现成池，接受新的任务 城市中段正在执行任务的现成，返回一个未执行的任务列表。我们可以结合这两种方式来优雅的终止现成池。首先优先使用下档方法关闭现成池，然后使用 ovtcommittent 摄影方法，等待现成池中的任务执行完毕或者超时时间到达。如果现成池中还有未执行完毕的任务， 调用现成迟到瞎当闹方法，中断所有正在执行任务的现成。如果有还没有开始执行的任务，则返回未执行的任务列表，可以选择是否执行。后续操作。最后代码部分大家可以自行参考笔记。小伙伴们关注威哥，更多精品内容持续与你分享！

大部分人可能都知道，在实际的开发中用到县城的地方，我们一般不直接 newslett 去创建一个县城， 当然也不建议去用 executives 中的自带的这几个线程池，所以大部分情况下我们都会向上图这种方法去自定一个线程池去使用。那么线程池中的这些核心参数你都真正理解是什么意思了吗？接下来我们详细探讨一下。 第一个参数是 corporate size， 它的意思就是说是核心现成数，看图中我框起来的这部分文字解释其实应该已经很清楚了。 第二个参数的意思呢？就是说最大形成数，表示当前现成时最多可以有多少个现成去执行任务。第三个和第四个参数一般是合起来使用的，一个表示 具体的数值，一个表示这个数值的单位，他就表示核心县城的空闲时间大概是多久，超过这个时间就会被销毁。 walk king 表示任务队列及存放我们提交任务的一个队列。 stride factory 是县城工厂，一般的话我们使用它主要是用来创建县城的，可以对当前的县城做一些定制，比如说起一些我们自己的名字，然后做一些其他方面的一些处理。 我们可以看一下这里是我自定义的一个县城，它里边主要是实现这个牛 sir 的方法，我们去创建一个 siri 就好了。 最后一个是拒绝策略及当前现成尺满了的话，新来的任务该怎么去处理？这里我使用的是现成尺自带的拒绝策略，当然我们也可以替换成我们自己想要的 策略在里边作为根据我们实际的业务场景去定制一些拒绝策略。县城池自带的四种拒绝策略，如下图框出来的绿色主食部分，我们接下来可以详细看一下每个拒绝策略是怎么实现的。 这是第一个线程，我们可以看到他的策略是把当前的线程交给主线程去执行及执行线程时任务提交的那个线程去执行。第二个策略是直接抛出一个异常， 第三个策略是什么也不做，极意味着丢弃这个县城。第四个策略则表示移除当前任务队列对手的那个任务，然后再重新提交当前这个任务。 以上就是现成十几个核心参数的一个介绍，这里我们看一下整体的一个总结。接下来我们再用一个实际的问题来感受一下这些参数实际的意义 作用。如上图红色哐哐哐出来的这个问题。首先他会创建五个核心线程去执行前五个任务，从第六个任务开始来的，都会放到任务队列中。 当任务队列放满以后，那么当前县城池中一共就有五十五个任务，当地五十六到六十个任务来了以后，会继续创建县城去执行，因为这个时候我们只创建了五个县城吗？我们最大限程数是十，所以还可以再创建五个。 截止目前为止，县城池中已经创建了十个县城，达到最大县城数限制。然后任务队列中也已经有五十个任务了，也达到了任务队列的限制，所以当年县城池已经满了， 这个时候第七十个到一百个。这四十个任务来了以后，有些人吃已经处于满载状态，所以他们会去执行拒绝策略了，这里 有给的拒绝策略是抛出一场，所以他会抛出四十个亿场。接下来我们验证一下我们所说的结论。首先在这里我自定义一个现成池，然后具体参数如上面所施， 其中县城工厂，我这里边自定义的一个县城工厂，我们可以看一下，主要给他的就是说起了一个名字，然后还有一个计数器， 主要方便我们在打印县城的时候，可以看到这是我们自定义的县城，还有他是第几个县城，然后拒绝策略在这里我也采用的是自定义的，这里采使用那个说出一段话来模拟抛出异常吧， 这里也用了计数器，所以刚才按照我们的结论，应该会这个计数器到四十。下面这段代码是提交一百个任务，并且其中可以看到每个 任务就是模拟呃执行三十三十秒，最后一行是获取当前任务队列中的任务数。 接下来我们执行一下，可以看到县城一共是有十个没有问题，然后拒绝策略的话，一共他是有四十个，也是没有问题的， 然后队列中的任务数是五十个，所以说呢，再来看我们上面的这个结论，他是结果是按照我们的想法来执行的，你还有什么问题吗？欢迎留言。

县城时的拒绝策略有哪些？先人石在接受任务时啊，如果说所有的工作县城都在忙哎，并且组色队列也是满满登登，那么此时呢，就会触发拒绝策略， 而现成池内部呢，提供了四种拒绝策略供我们选择。首先呢是 abot police， 这个也是现成池默认的拒绝策略，这种拒绝策略呢，会直接抛出一个叫做 rejected execution exception 的异常。 其次呢是 discard police， 这个拒绝策略是最简单的，他什么事都不做，把任务直接丢弃掉就可以了。 之后呢是 discar 的 odest police， 这个呢，会将阻塞堆列中排在最前面的任务丢弃掉，然后重新将任务提交给献仁池。至于是否能够添掐到阻塞堆列，那就要看天命了，看这一块。最后呢是 runs police， 这个会直接让提交任务的县城来自己处理当前任务，在这个位置，如果县城池提供的拒绝策略无法满足咱们的需求，也可以自定义拒绝策略，只需要仿照县城池自带的方式啊，实现一个叫做 rejected execution handler 的接口， 并且重写内部的一个叫做 rejected execution 方法，就可以实现自定义的咀嚼策略了，可以看字哈哈哈哈，哎呀，腰疼。

今天有人问我什么是县城池，那我们就来聊聊县城池吧。先看例子，有一个心理咨询中心，总共有十位心理咨询师， 今天有三个人上班，但是今天做心理治疗的人特别多，于是就把休息的七个心理咨询师喊过来加班，但是即使这样依然有点忙不过来， 外面设立的十个等待的位置也坐满了等待咨询的病人，于是再来的病人就无法接待了，就直接拒绝了。过了两个小时，等待的病人都咨询结束了，而且慢慢的加班的心理咨询师也空下来了， 这时老板就让空下来的心理咨询师提前回去，最后就剩下了今天本来应该上班的三个咨询师还在坚持上面的例子中。这个心理咨询中心就是县城十，每个咨询师就是一个县城，每个病人就是一个任务。上班的咨询师数量三就是核心县 成数，心理咨询师的总数时，就是现成词的最大现成数。外面的等待的位置时就是一个有界缓冲阻塞队列。 县城池至少会保证核心数量的县城数，当已有县城都在忙时，再有新的任务进来时，就会创建新的县城。当县城数达到最大数量时，再有新的任务就进入等待队列，当等待队列满的时候，就开始拒绝新的任务加入。 当任务处理完成后，会在指定时间后将空闲的线程销毁，但是至少要保证核心线程数的线程。以上便是线程值相关内容，我是戴着假发的程序员，欢迎！

现成时的工作流程是什么？我通过 xq 提交一个任务的时候，他是怎么去执行的？就是一开始提交任务之后，如果说他这个执行的任务的限制数没有达到核心线程数，那他就会创建一个核心线程数，就是说去执行任务， 当这个核心线程数使用完之后，再有任务过来，就会把任务放到这个队列里面，然后当队列买了之后，他就会去看看这个当前线程数是不是大于这个最大线程数，如果没有大于最大线程数，那他就会重新创建线程呢？ 去执行这个任务，当这个最大限制数也用完了，也达到了设置的这个数量，那他就会执行这个设置的拒绝策略。 然后一般我们会设置这个空闲线程的重合时间，如果说这个空闲线程数大于这个核心线程数量的话，他会把这个空闲线程数呢进行回收销毁。什么情况下会触发小鬼？ 比如说我们这个和谐线程数是五个吗？然后当前空线线程可能是六个，那有一个线程呢？他就会达到这个空线线程的时候就会被销毁。我怎么知道是空线呢？线程池里边有这么一个设置吧。