初识线程池

墨蓝 2022-05-18 08:37 230阅读 0赞

1.初识线程池：

根据系统自身的环境情况，有效的限制执行线程的数量，使得运行效果达到最佳。线程主要是通过控制执行的线程的数量，超出数量的线程排队等候，等待有任务执行完毕，再从队列最前面取出任务执行。

2.线程池作用：

减少创建和销毁线程的次数，每个工作线程可以多次使用

可根据系统情况调整执行的线程数量，防止消耗过多内存

3.使用

ExecutorService:线程池接口

ExecutorService pool = Executors.常见线程

eg：ExecutorService pool = Executors.newSingleThreadExecutor();

4.常见线程池

①newSingleThreadExecutor

单个线程的线程池，即线程池中每次只有一个线程工作，单线程串行执行任务

②newFixedThreadExecutor(n)

固定数量的线程池，没提交一个任务就是一个线程，直到达到线程池的最大数量，然后后面进入等待队列直到前面的任务完成才继续执行

③newCacheThreadExecutor（推荐使用）

可缓存线程池，当线程池大小超过了处理任务所需的线程，那么就会回收部分空闲（一般是60秒无执行）的线程，当有任务来时，又智能的添加新线程来执行。

④newScheduleThreadExecutor

大小无限制的线程池，支持定时和周期性的执行线程

5.实例

**publicclass**MyThread **extends** Thread \{

@Override

**publicvoid** run() \{

System.*out*.println(Thread.currentThread().getName() + "执行中。。。");

①newSingleThreadExecutor

**publicclass**TestSingleThreadExecutor \{

**publicstaticvoid** main(String\[\] args) \{

//创建一个可重用固定线程数的线程池

ExecutorService pool = Executors. newSingleThreadExecutor();

//创建实现了Runnable接口对象

Thread tt1 = **new** MyThread();

Thread tt2 = **new** MyThread();

Thread tt3 = **new** MyThread();

Thread tt4 = **new** MyThread();

Thread tt5 = **new** MyThread();

//将线程放入池中并执行

pool.execute(tt1);

pool.execute(tt2);

pool.execute(tt3);

pool.execute(tt4);

pool.execute(tt5);

//关闭

pool.shutdown();

result：

pool-1-thread-1执行中。。。

②newFixedThreadExecutor(n)

**publicclass** TestFixedThreadPool \{

**publicstaticvoid** main(String\[\] args) \{

//创建一个可重用固定线程数的线程池

ExecutorService pool = Executors.newFixedThreadPool(2);

//创建实现了Runnable接口对象

Thread t1 = **new** MyThread();

Thread t2 = **new** MyThread();

Thread t3 = **new** MyThread();

Thread t4 = **new** MyThread();

Thread t5 = **new** MyThread();

//将线程放入池中进行执行

pool.execute(t1);

pool.execute(t2);

pool.execute(t3);

pool.execute(t4);

pool.execute(t5);

//关闭线程池

pool.shutdown();

result：

pool-1-thread-1执行中。。。

pool-1-thread-2执行中。。。

pool-1-thread-1执行中。。。

pool-1-thread-2执行中。。。

pool-1-thread-1执行中。。。

③newCacheThreadExecutor

**publicclass** TestCachedThreadPool \{

**publicstaticvoid** main(String\[\] args) \{

//创建一个可重用固定线程数的线程池

ExecutorService pool = Executors.newCachedThreadPool();

//创建实现了Runnable接口对象

Thread t1 = **new** MyThread();

Thread t2 = **new** MyThread();

Thread t3 = **new** MyThread();

Thread t4 = **new** MyThread();

Thread t5 = **new** MyThread();

//将线程放入池中进行执行

pool.execute(t1);

pool.execute(t2);

pool.execute(t3);

pool.execute(t4);

pool.execute(t5);

//关闭线程池

pool.shutdown();

result：

pool-1-thread-1执行中。。。

pool-1-thread-2执行中。。。

pool-1-thread-4执行中。。。

pool-1-thread-3执行中。。。

pool-1-thread-5执行中。。。

初识线程池

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关【Java | 多线程案例】——初识线程池

相关【JavaEE】初识线程

相关【Java多线程】线程池(一)与线程池的初识

相关【Java线程】“打工人”初识线程池及自定义线程池实战

相关 Java 线程池初识

相关 java线程池初识

相关 ThreadPoolExcutor（线程池）初识

相关并发：线程初识

相关初识线程池

相关初识线程池