Cheug's Blog

当前位置:网站首页 / JAVA / 正文

线程池

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.RunnableCallable的区别

          Runnablerun方法没有返回值

          Callablecall方法有返回值,一般返回值也没用

案例演示

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.