法解读

简单来说线程池就好比一块鱼塘鱼塘中的每条鱼就是一个线程。

那么为什么要有这个线程池呢就好比

一个“渣女\渣男”当他和A在一起的时候如果想和B在一起那么就需要先想办法和A分手再和B搞好关系最终和B在一起。

如果她和A谈的时候已经找好了B

其实线程池也就大概这个作用里面存放一些线程需要用的时候直接拿来使用。

package

java.util.concurrent.ExecutorService;

import

java.util.concurrent.Executors;public

class

Executors.newSingleThreadExecutor();}

new

出来的那么它是如何被实例化的呢其实这里就使用了一种设计模式工厂模式。

为什么要有工厂模式

其实工厂模式就时给Java中的构造方法填坑的我们的构造方法其实时有很大缺陷的我们来看以下例子。

double

但是构造方法也是方法此时的方法由于参数个数和参数的类型都相同就会编译失败那么就没办法满足期望

此时这个类中又两个静态方法一个是构造笛卡尔坐标系并且返回。

一个是构造及坐标系并且返回对象。

Point

PointFactory.makePintByXY(10,20)

Point

PointFactory.makePintByRA(12,63)

此时通过PointFactory类来给Point类传入需要的值就可以了。

其实线程的创建又被封装到了一个叫做ThreadPoolExecutor的类中

corPoolSize.

就好比一个公司中有正式员工核心线程和实习生总的员工数目不能超过一定的值。

当人手不够用就招实习生这样既可以满足效率的需求又可以避免过多的开销。

第四个TimeUnit

unit是用来设置非核心线程闲置超时时长keepAliveTime的单位。

当一个非核心线程的闲置时间超过这个参数所设定的时长时该线程就会被销毁掉。

第五个比较重要

第六个是线程池的拒绝策略也就是当所有线程都处于忙碌状态如果还往线程池中添加元素线程池所做的操作。

下面来单独讲讲第六个参数拒绝策略

所谓的拒绝策略其实就是如果线程池中每个线程都是处于忙碌的状态如何应对新来的线程任务。

举个例子如果我周一到周五都是满课此时我一朋友让我给他去代课那么此时我如何应对此时就会有相应的应对策略

AbortPolicy默认策略这是默认的拒绝策略它会抛出一个未检查的RejectedExecutionException以指示任务被拒绝。

也就是我本来都满课了朋友还让我去代课此时我就直接崩溃代课和我自己的课我都不去上了直接崩溃CallerRunsPolicy这个策略不会抛出异常。

相反它会将任务退回给调用线程让它自己运行这个任务。

也就是让我朋友自己去上课。

DiscardOldestPolicy此策略会丢弃队列中等待最久的任务并立即返回给调用者。

也就是我丢弃我课程中一节课去给他代课。

DiscardPolicy这个策略会静默地丢弃被拒绝的任务。

也就是说它不会抛出任何异常也不会通知任务被拒绝。

也就是我拒绝去给他代课我自己上自己的课。

然后我朋友也不去上课了那么这个课任务)

四.自己实现一个线程池

java.util.concurrent.ArrayBlockingQueue;

import

java.util.concurrent.BlockingQueue;class

MyPoolDemo

ArrayBlockingQueue(1000);//通过这个方法,把任务添加到队列当中public

void

{//如果队列中没有元素,那就阻塞等待//一旦队列中有了任务,那么就立即执行take方法获取到任务并且开始执行Runnable

task

RuntimeException(e);}});t.start();}}}

public

4.一但任务队列里面有元素,这20个线程就会立马获取到,并且执行*/MyPoolDemo

myPoolDemo

这个阻塞队列中。

为什么要使用阻塞队列呢当线程池中的线程都在工作此时就直接等待阻塞。

2.submit

方法接受一个实例化好的Runnable类型的任务负责往队列中添加元素

MyPoolDemo(int

由运行结果可以得出当线程数量为20的时候可以看到任务被随即执行完了。

总结Java线程池是Java并发编程中一个重要的概念它用于管理和控制线程的创建、销毁以及任务提交和执行。

线程池的主要目的是减少创建和销毁线程的开销提高性能。