美文网首页
Java Executors学习(二)

Java Executors学习(二)

作者: 小裁缝先生 | 来源:发表于2017-08-18 00:27 被阅读0次

    在上一篇文章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源代码。

    eclipse查看jdk源代码操作顺序

    在添加完jdk的源码之后就可以看到Executors的源码,我们暂时只看下newFixedThreadPool,newSingleThreadExecutor,newCachedThreadPool,newScheduledThreadPool这四个类的方法。

    newFixedThreadPool newSingleThreadThreadExecutor newCachedThreadPool ScheduledThreadPoolExecutor

    从上面三种图可以看出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的泛型类型

    ExecutorService Executor

    处理异常方面,submit可以通过返回的Future.get()方法获取线程异常,以进行必要的逻辑处理。

    execute的例子,在Java Executors线程池入门中已经写过,在这里我们只写submit的列子,

    submit方法

    运行结果如下:

    运行结果

    java8中多线程代码的编写

    从上面的代码,可以看出写一个多线程还需要定义一个实现了callable的内部类,但是在java8之后这样的写法显得就有些繁琐,下面给出java8的示例

    java8写法

    到这里为止,这篇文章就结束了,写的比较的粗浅,希望对大家了解Executors有所帮助,也希望多线程大神可以留言多多指教。

    相关文章

      网友评论

          本文标题:Java Executors学习(二)

          本文链接:https://www.haomeiwen.com/subject/eyrorxtx.html