线程池

线程池的概念和原理

线程池:其实就是一个容纳多个线程的容器,其中的线程可以反复使用,省去了频繁创建线程对象的操作,无须反复穿古剑线程而消耗过多资源。

简单来说,线程池就是在程序第一次启动的时候,就创建多个线程,保存到一个集合汇总,当我们想要使用线程的时候,就可以从集合中取出来线程使用。

当我们使用完毕一个线程,并不是删除掉线程,而是需要把线程归还给线程池。

线程池的代码实现

线程池:JDK1.5之后提供的。
java.util.concurrent.Executors:线程池的工厂类,用来生成线程池。
Executors类中的静态方法:
1. static ExecutorsService newFixedThreadPool(int nThreads):创建一个可重用固定线程数的线程池。
参数:
int nThreads:创建线程池中包含的线程数量。
返回值:
ExecutorService接口,返回的是ExecutorService接口的实现类对象,我们可以使用ExecutorService接口接受(面向接口编程)

2. java.util.concurrent.ExecutorService:线程池接口
用力从线程池中获取线程,调用start方法,执行线程任务。
    submit(Runnable task)提交一个Runnable任务用于执行
3. 关闭/销毁线程池的方法
    void shutdown()

线程池的使用步骤

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

代码演示:

package M1.day27.day29;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class xianchengchi {    
    public static void main(String[] args) {        
        //1. 创建线程池        
        ExecutorService es = Executors.newFixedThreadPool(2);        
        //3. 调用submit方法,调用线程,执行run方法        
        es.submit(new RunnableImpl());        
        //线程池会一直开启,使用完了线程,会自动把线程归还给线程池,线程可以继续使用        
        es.submit(new RunnableImpl());        
        es.submit(new RunnableImpl());        
        //4. 调用shutdown销毁线程池(不建议执行,因为会下面将无法使用线程池)        
        es.shutdown();    
    }
}
package M1.day27.day29;
/*
2. 创建一个类,视线Runnable接口,重写run方法,设置线程任务 
*/
public class RunnableImpl implements Runnable{    
    @Override    
    public void run() {        
        System.out.println(Thread.currentThread().getName()+"创建了一个新的线程");    
    }
}
原文地址:https://www.cnblogs.com/Xiaoming0/p/13904806.html