Java线程池总结--线程池的代码实现

以创建 newFixedThreadPool 定长线程池为例：

首先，java.util.concurrent.Executors:线程池的工厂类，用来生成线程池 其次，Executors类中的静态方法： static ExecutorService newFixedThreadPool(int nThreads) 创建一个可重用固定线程数的线程池

参数： int nThreads：创建线程池中包含的线程数量 返回值： ExecutorService接口，返回的是ExecutorService接口的实现类对象，我们可以使用ExecutorService接口接收（面向接口编程） java.util.concurrent.ExecutorService:线程池接口，用来从线程池中获取线程，调用start方法，执行线程任务。

submit（Runnable task）提交一个Runnable任务用于执行

关闭/销毁线程池方法 ： void shutdown()

线程池的使用步骤：

1、使用线程池的工厂类Executors里面提供的静态方法newFixedThreadPool生产一个指定线程数量的线程池。 2、创建一个类，实现Runnable接口，重写run方法，设置线程任务。 3、调用ExecutorService中的方法submit，传递线程任务，开启线程，执行run方法。 4、调用ExecutorService中的方法shutdown销毁线程池（不建议执行）。

代码如下：

创建一个类，实现Runnable接口，重写run方法，设置线程任务

public classRunnableImp1 implements Runnable {
          
   
	public void run() {
          
   
		System.out.println(Thread.currentThread().getName()+"创建了一个新的线程，执行");
	}
}

创建Demo01ThreadPool类

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Demo01ThreadPool {
          
   
	public static void main(String args[]) {
          
   
		//1、使用线程池的工厂类Executors里面提供的静态方法newFixedThreadPool生产一个指定线程数量的线程池。
		ExecutorService es=Executors.newFixedThreadPool(2);//线程池数量为2
		
		//2.调用ExecutorService中的方法submit，传递线程任务，开启线程，执行run方法。
		es.submit(new RunnableImp1());

		//3.调用ExecutorService中的方法shutdown销毁线程池（不建议执行）
		es.shutdown();//使用后会把线程池销毁，就无法执行新的线程了。
	}
}