程序启动一个新线程的成本是很高的,因为涉及到要和操作系统进行交互,而使用线程池可以...
程序启动一个新线程的成本是很高的,因为涉及到要和操作系统进行交互,而使用线程池可以很好的提高性能,尤其是程序中当需要创建大量生存期很短的线程时,应该优先考虑使用线程池.
线程池的每一个线程执行完毕后,并不会死亡,会再次回到线程池中变成空闲状态,等待下一个对象来调用,类比于数据库连接池.JDK1.5以后,java内置线程池.
JDK5新增了一个Executors工厂类来产生线程池,通过查文档我们发现,产生线程池很多方法,常用的有以下几个方法:
- public static ExecutorService newCachedThreadPool()
- public static ExecutorService newFixedThreadPool(int nThreads)
- public static ExecutorService newSingleThreadExecutor()
这些方法的返回值都是ExecutorService对象,该对象表示一个线程池,可以执行Runnable对象或Callable对象代表的线程,提供了如下方法:
submit(Runnable task);
submit(Callable<T> task);
使用线程池开辟一个新线程的步骤,
1.创建线程池对象
2.创建Runnable实例
3.提交Runable实例
4.关闭线程池(选择)
下面通过代码来演示:
package com.wang.reflect;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;class MyRunnable implements Runnable{ @Override public void run() { for(int i=0;i<100;i++){ System.out.println(Thread.currentThread().getName()+"::"+i); } }}public class ThreadPoolDemo { public static void main(String[] args) { //创建线程池对象 ExecutorService service = Executors.newFixedThreadPool(2); //执行Runnable对象代表的线程 service.submit(new MyRunnable()); service.submit(new MyRunnable()); //关闭线程池 service.shutdown(); }}讲到了线程池,就不得不提多线程实现的第三种方法,实现Callable<T>接口,这种方法实现的多线程,就是依赖于线程池而存在的,下面用代码来演示:
package com.wang.reflect;import java.util.concurrent.Callable;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;class MyCallable implements Callable{ //Callable是一个带泛型的接口,这里先不使用 @Override public Object call() throws Exception { for(int i=0;i<100;i++){ System.out.println(Thread.currentThread().getName()+"::"+i); } return null; } }public class CallableDemo { public static void main(String[] args) { //创建线程池对象 ExecutorService service = Executors.newFixedThreadPool(2); //执行Runnable对象代表的线程 service.submit(new MyCallable()); service.submit(new MyCallable()); //关闭线程池 service.shutdown(); }}
版权声明
本文仅代表作者观点，不代表百度立场。
本文系作者授权百度百家发表，未经许可，不得转载。
上一篇：2017区块链概念股龙头 下一篇：Java笔记6
