线程池
2019-04-22 / JAVA / 904 次围观 / 0 次吐槽 /线程池概述
程序启动一个新线程成本是比较高的,因为它涉及到要与操作系统进行交互。而使用线程池可以很好的提高性能,尤其是当程序中要创建大量生存期很短的线程时,更应该考虑使用线程池。线程池里的每一个线程代码结束后,并不会死亡,而是再次回到线程池中成为空闲状态,等待下一个对象来使用。在JDK5之前,我们必须手动实现自己的线程池,从JDK5开始,Java内置支持线程池
Java的内置线程池
1.JDK5新增了一个Executors工厂类来产生线程池,有如下几个方法
public static ExecutorService newFixedThreadPool(int nThreads)
public static ExecutorService newSingleThreadExecutor()
2. 这些方法的返回值是ExecutorService对象,该对象表示一个线程池,
可以执行Runnable对象或者Callable对象代表的线程。
它提供了如下方法
Future<?> submit(Runnable task)
<T> Future<T> submit(Callable<T> task)
3.使用步骤:
1.创建线程池对象
2.创建Runnable实例
3.提交Runnable实例
4.关闭线程池es.shutdown();
4.Runnable和Callable的区别
Runnable的run方法没有返回值
Callable的call方法有返回值,一般返回值也没用
案例演示
public class Demo{ public static void main(String[] args) { //1.创建线程池 ExecutorService es = Executors.newFixedThreadPool(5); //2.添加任务-方式一 for(int i=0;i<10;i++){ es.submit(new Runnable() { @Override public void run() { System.out.println("任务 " + Thread.currentThread()); } }); } //3.添加任务-方式二 for(int i=0;i<10;i++){ es.submit(new MyTask()); } } } class MyTask implements Callable<Integer>{ @Override public Integer call() throws Exception { System.out.println("任务 " + Thread.currentThread()); return 110; } }
Powered By Cheug's Blog
Copyright Cheug Rights Reserved.