在上一篇文章Java Executors线程池入门中,简单的介绍了几种创建线程的方法,在这篇文章中我们会从下面三方面出发略微深入的了解下Executors。
源码出发粗略的讲解下,这几种方法是怎么写的。
在eclipse中通过“Ctrl+Shift+t”快捷键打开“Open Type”窗口,在窗口的输入框中输入“Executors”,正常情况下,应该只会搜索到一个,如果出现多个就选择java.util.concurrent包下面的。
如果之前没有添加过源码,页面中就会提示“Source not found”。遇到这样的情况,就点击“Attach Source”按钮。在弹出框中,选择“External location”,然后选择“External File”,然后从jdk的安装目录中双击打开src压缩包,即可查看jdk源代码。
在添加完jdk的源码之后就可以看到Executors的源码,我们暂时只看下newFixedThreadPool,newSingleThreadExecutor,newCachedThreadPool,newScheduledThreadPool这四个类的方法。
从上面三种图可以看出newFixedThreadPool,newSingleThreadThreadExecutor,newCachedThreadPool三个方法都调用了ThreadPoolExecutor。下面就针对ThreadPoolExecutor参数做个简单介绍,
第一个参数(corePoolSize):线程池中始终保持的线程个数,即便线程是空闲的(在设置了allowCoreThreadTimeOut之后,线程在空闲时会被释放)
第二个参数(maximumPoolSize):线程池中最大的个数
第三个参数(keepAliveTime):当最大的线程数大于设置的core线程数时,线程池中空闲的线程在被终止之前等待新任务的时间
第四个参数(TimeUnit):keepAliveTime时间的单位
第五个参数(workQueue):队列,用于在线程被执行之前管理线程
可以看出newFixedThreadPool调用ThreadPoolExecutor时corePoolSize,maximumPoolSize为用户传递的值,newSingleThreadThreadExecutor调用ThreadPoolExecutor时corePoolSize,maximumPoolSize设置为1,这样也符合当线程的思路,newCachedThreadPool调用时corePoolSize设置为0,maximumPoolSize设置最大,workQueue使用了SynchronousQueue,这样也符合它的可扩展特性。ScheduledThreadPoolExecutor的实际实现方法,corePoolSize为用户传参值,maximumPoolSize为最大值,workQueue使用了DelayedWorkQueue。
execute以及submit两个方法的使用以及区别
从源码中,可以看出newFixedThreadPool,newSingleThreadThreadExecutor,newCachedThreadPool都返回了ExecutorService类型,newScheduledThreadPool返回了ScheduledExecutorService,其实ScheduledExecutorService也是继承了ExecutorService。而ExecutorService继承了Executor。(上面的关系,可以在eclipse中通过F4快捷键查看).
从源码中可以看出execute是由Executor提供的,submit是由ExecutorService提供的
从接收参数方面,execute只接收实现了Runnable接口的任务,submit除了可以接收实现了Runnable接口的任务,还可以接收实现了Callable接口的任务
从返回值方面,execute是没有返回值的,而submit是会返回Future的结果,也可在调用时确认返回Future的泛型类型
处理异常方面,submit可以通过返回的Future.get()方法获取线程异常,以进行必要的逻辑处理。
execute的例子,在Java Executors线程池入门中已经写过,在这里我们只写submit的列子,
运行结果如下:
java8中多线程代码的编写
从上面的代码,可以看出写一个多线程还需要定义一个实现了callable的内部类,但是在java8之后这样的写法显得就有些繁琐,下面给出java8的示例
到这里为止,这篇文章就结束了,写的比较的粗浅,希望对大家了解Executors有所帮助,也希望多线程大神可以留言多多指教。