首先我们先来写一个简单的线程池代码:

它的运行结果:

此时我们在给它添加一个关闭线程池的代码

它的运行结果为:

此时我们的main方法为主线程,我们自己定义的pool为子线程,运行时会先执行主线程然后执行我们的关闭线程池操作,当代码块再去执行子线程时就会出现错误
现在我们再来创建一个固定大小的线程池

它的运行结果为:

此时子线程会一次性打印五个线程,谁先进谁先打印
接下来再创建一个可缓冲的线程池

它的运行结果为

它的运行结果非常快(取决于你的CP)
首先我们先来写一个简单的线程池代码:
它的运行结果:
此时我们在给它添加一个关闭线程池的代码
它的运行结果为:
此时我们的main方法为主线程,我们自己定义的pool为子线程,运行时会先执行主线程然后执行我们的关闭线程池操作,当代码块再去执行子线程时就会出现错误
现在我们再来创建一个固定大小的线程池
它的运行结果为:
此时子线程会一次性打印五个线程,谁先进谁先打印
接下来再创建一个可缓冲的线程池
它的运行结果为
它的运行结果非常快(取决于你的CP)
本文标题:Spark线程池介绍
本文链接:https://www.haomeiwen.com/subject/xkrzlctx.html
网友评论