java基础--28.线程池简介以及实际应用
2016-12-16 16:59
405 查看
线程池简介
程序启动一个新线程的成本是比较高的,因为它涉及到要与操作系统进行交互。而使用线程池可以很好的提高性能,尤其是当程序中要创建大量生存期很短的线程时,更应该考虑使用线程池。
线程池的好处:线程池里的每一个线程代码结束后,并不会死亡,而是再次回到线程池中成为空闲状态,等待下一个对象来使用。
在JDK5之前,我们必须手动实现自己的线程池,从JDK5开始,Java内置支持线程池
线程池的创建
JDK5新增了一个Executors工厂类来产生线程池,有如下几个方法public static ExecutorService newCachedThreadPool()
public static ExecutorService newFixedThreadPool(int nThreads)
public static ExecutorService newSingleThreadExecutor()
这些方法的返回值是ExecutorService对象,该对象表示一个线程池,可以执行Runnable对象或者Callable对象代表的线程。它提供了如下方法
Future<?> submit(Runnable task)
<T> Future<T> submit(Callable<T> task)
案例演示
创建线程池对象的方法创建Runnable实例
提交Runnable实例
关闭线程池
//创建实现Runnable接口的实例对象 public class MyRunnable implements Runnable { @Override public void run() { for (int x = 0; x < 100; x++) { System.out.println(Thread.currentThread().getName() + "--" + x); } } } /* * 如何实现线程池的代码? * A:创建一个线程池对象,控制要创建几个线程对象 * static ExecutorService newFixedThreadPool(int nThreads) * * B:这种线程池的线程可以执行: * Runnable对象或者Callable对象代表的线程 * 创建一个类实现Runnable接口 * * C:启动线程调用如下方法: * Future<?> submit(Runnable task) * <T> Future<T> submit(Callable<T> task) * * D:执行完之后想结束线程,可以吗? * 可以 * void shutdown() 启动一次顺序关闭,执行以前提交的任务,但不接受新任务。 */ public class ExecutorsDemo { public static void main(String[] args) { //通过工厂方法 创建一个拥有两个线程的线程池对象 ExecutorService pool = Executors.newFixedThreadPool(2); //提交一个 Runnable 任务用于执行 pool.submit(new MyRunnable()); pool.submit(new MyRunnable()); //启动一次顺序关闭,执行以前提交的任务,但不接受新任务。结束线程池 pool.shutdown(); } }
使用匿名内部类实现多线程
线程池的创建和使用都比较复杂,在开发中我们会尽量简化这些过程–使用匿名内部类
public class AnonymousThreadDemo { /** * 使用匿名内部类实现多线程 */ public static void main(String[] args) { //方式1:直接new Thread创建线程 new Thread() { public void run() { for (int x = 0; x < 100; x++) { System.out.println(Thread.currentThread().getName() + ":"+ x); } } }.start(); //方式2:通过Runnable接口创建线程 new Thread(new Runnable() { @Override public void run() { for (int x = 0; x < 100; x++) { System.out.println(Thread.currentThread().getName() + ":"+ x); } } }) { }.start(); //方式x:这种方式仅仅会出现在面试题中,运行的代码只是Thread类重写的run方法中的代码 new Thread(new Runnable() { @Override public void run() { for (int x = 0; x < 100; x++) { System.out.println("hello" + ":"+ x); } } }) { @Override public void run() { for (int x = 0; x < 100; x++) { System.out.println("world" + ":"+ x); } } }.start(); } }
相关文章推荐
- (7)java5线程并发库的应用(线程池) 以及在实际项目中的使用。。
- java基础数组的定义与初始化以及集合框架的应用
- 视区相关单位vw, vh..简介以及可实际应用场景
- Java Thread 的概念以及基础应用
- Java线程池的基础应用
- 委托--事件--基础以及在现在做的项目上的实际应用(三)
- 视区相关单位vw, vh..简介以及可实际应用场景
- 视区相关单位vw, vh..简介以及可实际应用场景
- JAVA_SE基础——36.static的实际应用
- 委托--事件--基础以及在现在做的项目上的实际应用(一)
- Java基础--线程池的应用
- Java自学之路-Java基础教程-28:Java和HTML代码在JSP中的应用和运行
- [零基础学JAVA]Java SE应用部分-28.Java IO操作(02) 推荐
- 黑马程序员--Java基础--awt详解以及简单应用
- 【从0到1学习Java线程池】Java线程池的简介以及使用
- java语言基础(33)——面向对象(父类中没有无参构造编译报错——无法将类 xxx中的构造器 xxx应用到给定类型 实际参数列表和形式参数列表长度不同)
- Java并发28:ThreadLocal学习笔记-简介、基本方法及应用场景
- 【java基础】static静态代码块,构造器代码块以及局部代码块的区别与应用!
- 委托--事件--基础以及在现在做的项目上的实际应用(四)
- 视区相关单位vw, vh..简介以及可实际应用场景