文学鉴赏

java虚拟机多线程进阶篇总结 好的感情懂得彼此心疼

作者:本站 | 分类:现代文学| 浏览:125

java虚拟机多线程进阶篇总结 好的感情懂得彼此心疼

java虚拟机多线程进阶篇总结更新时间:2019年06月07日16:00:23投稿:laozhang在本篇内容里小编给大家整理了关于java虚拟机多线程进阶篇的相关知识点内容,有兴趣的朋友们跟着参考下。

1.线程池基本参数以()这种创建方式为例:大家想象,假如你创建一个线程池,你想这个池子有些什么参数呢?首先这个池子必须要有一个最大值;然后还希望这个池子的线程数量有一个警戒线,到了这个警戒线的位置说明线程池暂时已经满了,如果这个时候还有人过来拿线程,我们就要把这些人抓起来扔到一个地方去让他们排队,告诉他们:请稍等,等我们的线程有空闲的时候再来处理你的事;再然后假如人排队的地方都满了,玛德,好多人,于是线程池就想办法东拼西凑又多搞出来了几个线程去处理了;最后,假如那搞出来的这几个线程还是不够用,并且排队的地方总是满的,于是线程池生气了,就这么多人可以了,如果还有人过来的赶紧让它滚蛋;这里我们需要知道几个东西:1这里的警戒线叫做核心线程池大小(corePoolSize);2.最大值还是叫做线程池线程最大数量(maximumPoolSize)3.排队的地方叫做队列(BlockingQueueRunnable),这个队列用于保存我们的线程要做的任务,这个队列有好几种类型,我们后面会分析的;4.还有一个参数是keepAliveTime:线程存活时间,意思就是当池中总共的线程大于核心线程池数目,那就关闭池子中的空闲线程,要保证线程总数维持在核心线程池数目或者之下;现在我们来理一下逻辑:池中当前线程数量=核心线程池大小:线程池直接创建线程处理池中当前线程数量核心线程池数量:将多余的任务放进队列队列满了,还有任务过来,线程池继续创建线程,直到到达线程池最大数量还有任务过来,这里会有一个饱和策略,默认是直接丢弃继续过来的任务2.线程池种类我们上一节使用的线程池如下所示:ExecutorServicepool=(3);(newRunnableImpl("玩游戏"));我们是通过Executors这个类的静态方法创建的一个线程池,于是进入这个类我们看看这个类还有没有创建其他种类线程池的方法,居然还真有。 。

。

我们先简单说说这四种分别是干嘛用的;newFixedThreadPool(int):这个线程池就是上面说的那种方式,也是我们重点要看源码的线程池;newSingThreadExecutor():这个不能说是线程池了,因为里面这里面只有一个线程,而且自带一个队列,只要有任务来了就会把任务保存到队列中,然后这个线程就慢慢的一个一个执行。

newCachedThreadPool():无限线程的线程池newScheduledThreadPool(int):一个定时的线程池,可以让线程池中的线程延迟指定时间再执行任务;继承结构我们可以看到实际上实例化的是一个ThreadPoolExecutor对象,这个对象作用是用线程去处理传进去的任务:我们看一下这个继承结构,Executor接口:只是定义了execute();这个方法,等待子类去实现;ExecutorService接口:继承Execute接口,并又声明了shutdown()方法和submit()方法,等待子类去实现AbstractExecutorService抽象类:初步实现了submit()方法,但是内部调用的execute()方法去执行任务ThreadPoolExecutor类:这个类是实现了很多的方法,将shutdown()和execute()方法都给实现了;4.看看execute()方法源码下面我们主要就是看看execute()方法的内部是怎么实现的,知道了这个的实现原理也就差不多了 publicvoidexecute(Runnablecommand){if(command==null)thrownewNullPointerException();intc=();    //workCountOf(c)表示当前线程池中线程的数量;这里进行一个判断,当线程池中线程数目小于核心池子数目时,  就调用addWorker()方法将我们的任务添加进去,等下可以看到addWorker()方法内部其实就是创建线程并处理请求,  就类似newThread(xxx).start()这种方式    if(workerCountOf(c)corePoolSize){if(addWorker(command,true))return;c=();}//如果当前线程数目大于核心线程并且任务放入一个队列成功,内部还会再次进行线程池状态判断,这里的&&用得比较精髓(短路作用),好好体会一下,  假如不是运行状态那就会执行remove方法删除队列中的任务,如果是运行状态直接进入elseif,这里的目的是线程池中已经关闭了,我们添加一个null任务  表示线程池不再处理任务    if(isRunning(c)&&(command)){intrecheck=();if(!isRunning(recheck)&&remove(command))reject(command);elseif(workerCountOf(recheck)==0)addWorker(null,false);}//能执行到这里,说明上面两个if中的条件都不满足,条件应该是:当前线程大于核心线程,并且向队列中添加任务失败,换句说说就是对列已经满了,装不下这么多任务  于是我们reject()方法内部就是对这些多余的任务进行处理的一些策略,默认就是直接丢弃elseif(!addWorker(command,false))reject(command);}对于面这三种情况的判断还是很清楚的,我们忽略很多细节,因为我们的目的是要对整个逻辑有个大概的了解,而不是去完全消化这些源码,这很不现实,要想理解透彻只能慢慢的去研究...我们来看看最重要的addWorker()这个方法,这个方法就是线程池将我们传进来的newRunnable(xxx)进行处理,其实内部就是用newThread(xxxx).start()处理,只是出于线程池中会进行很多的条件判断以及将Runnable()做进一步的封装,我们了解就好,代码如下:privatebooleanaddWorker(RunnablefirstTask,booleancore){//这里删除很多的条件判断的代码    ..........        booleanworkerStarted=false;booleanworkerAdded=false;Workerw=null;try{finalReentrantLockmainLock=;//注意下面这两行,其实就是将我们传进来的Runnable()进行封装成Worker,在Worker构造器里面会newThread()并且保存起来       这样做的一个好处就是直接将一个线程和一个Runnable进行绑定,我们随时可以从Worker中获取线程然后调用start()方法就ok了       w=newWorker(firstTask);finalThreadt=;if(t!=null){();try{//此处删除一些            .........if(rsSHUTDOWN||(rs==SHUTDOWN&&firstTask==null)){if(())//precheckthattisstartablethrownewIllegalThreadStateException();              //由于会有很多个Worker,于是我们会创建HashSetWorkerworkers=newHashSetWorker(),用于保存所有的worker,后续直接遍历处理很方便              而且我们所说的线程池的本质就是这个workers,也就是一个HashSet              (w);              ints=();if(slargestPoolSize)largestPoolSize=s;workerAdded=true;}}finally{();}          //下面这个if语句中就是一个无限循环的去执行线程的start()方法if(workerAdded){();workerStarted=true;}}}returnworkerStarted;}说出来你可能不信,我有点没看懂这里,因为最后的那个start()方法总感觉有点问题,但是说不上来,你们觉得这个start()方法之后,CPU来运行这个线程会执行哪个run()方法?是我们传进去的类的run()方法?还是worker的run()方法呢?我们看看下面这两行代码,Worker构造器中的新建线程的代码就不截图了,我们把下面这几行代码变化一下:Workerw=newWorker(firstTask);finalThreadt=;........()变化后:  Workerw=newWorker(firstTask);//firstTask是我们传进去的实现了Runnable接口的类,但是Worker也实现了Runnable接口 finalThreadt=getThreadFactory().newThread(()。

上一篇:斯里兰卡连环爆炸致逾200人身亡 两名中国公民在袭击中遇难     下一篇:纪录片《决战兰州》亮相央视 感受幸福
最近更新
精彩推荐
友情链接