美文网首页
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学习(二)

    在上一篇文章Java Executors线程池入门中,简单的介绍了几种创建线程的方法,在这篇文章中我们会从下面三方...

  • Java Consurrency 《Thread Pool Ex

    Java Consurrency 《Thread Pool Executors》 Executors 为 Exec...

  • 线程池

    线程池 原创 无尘粉笔 粉笔社区 昨天 Java线程池的Executors的使用 Java通过Executors提...

  • Java☞线程池

    java.util.concurrent.Executors类java.util.concurrent.Execu...

  • Java 线程池(Executor)

    Java 线程池(Executor) ThreadPoolExecutor使用 执行结果: Executors使用...

  • ThreadPool

    Executors创建的4种线程池的使用 Java通过Executors提供四种线程池,分别为: newCache...

  • 11、多线程之线程池

    java 通过Executors工厂类一共可以创建四种类型的线程池,通过Executors.newXXX即可创建。...

  • JAVA并发问题-线程池ThreadPool

    JAVA中提供的线程池 Executors工厂类 Executors工具类提供了5种线程池的创建方法 每种线程池都...

  • newFixedThreadPool原理

    @(Executors)[newFixedThreadPool] [TOC] java线程池 在面向对象编程中,创...

  • Java 线程池详解

    Java 线程池 Java 线程池模型的关键几个类和接口包括:Executor,Executors,Executo...

网友评论

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

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