前言
创建和销毁一个线程时,这点损耗是微不足道的,但是当需要频繁的创建和销毁多个线程时,这个成本是不可忽视的,于是就有大佬创建了线程池,借助线程池来减少其中的成本。
目录
前言
一、线程池的使用原理
二、线程池的参数介绍
三、使用Executors 创建常见的线程池
四、线程池的使用案例
五、线程池的模拟实现
六、线程池的优点
结语
一、线程池的使用原理
当有对象申请创建线程池时:
所以在使用线程池的线程的时候,线程已经提前被创建好了,并且用户不使用这个线程时,这个线程会被线程池回收,等待下一次调用。
二、线程池的参数介绍
有很多接口丰富的线程池类,本文这里只讲一个(讲解接口最丰富的类)
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler);
三、使用Executors 创建常见的线程池
Executors.newFixedThreadPool(int num);//创建一个固定线程数量的线程池
Executors.newCachedThreadPool();//创建出一个线程数目动态变化的线程池
Executors.newSingleThreadExecutor();//包含单个线程的线程池(比原生api更简单)
Executors.newScheduledThreadPool();//类似于定时器,可能由多个线程执行
都是依靠使用submit方法,将任务添加到线程中。
四、线程池的使用案例
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class Main {public static void main(String[] args) {ExecutorService service = Executors.newFixedThreadPool(4);service.submit(new Runnable() {@Overridepublic void run() {while(true){System.out.println(Thread.currentThread().getName()+111);}}});service.submit(new Runnable() {@Overridepublic void run() {while(true){System.out.println(Thread.currentThread().getName()+222);}}});}
}
运行截图:
五、线程池的模拟实现
class MyExecutor{private int num;//线程数量MyExecutor(int num){this.num = num;MyTake myTake = new MyTake();myTake.start();}volatile BlockingQueue<Runnable> queue = new LinkedBlockingQueue<>();static Object object = new Object();class MyTake extends Thread{@Overridepublic void run() {for (int i = 0; i < num; i++) {Thread thread = new Thread() {@Overridepublic void run() {synchronized (object) {try {//为了使线程池一直处于运行状态while(true){//执行任务while (queue.isEmpty()) {object.wait();}Runnable runnable = queue.take();runnable.run();}} catch (InterruptedException e) {e.printStackTrace();}}}};thread.start();}}}public void submit(Runnable runnable){synchronized (object){try {queue.put(runnable);object.notify();} catch (InterruptedException e) {e.printStackTrace();}}}
}
六、线程池的优点
1)降低资源消耗:减少线程的创建和销毁带来的性能开销;
2)提高响应速度:当任务来时可以直接使用,不用等待线程创建;
3)可管理性:进行统一的分配、监控,避免大量的线程之间因互相抢占系统资源导致的阻塞现象。
结语
这篇博客如果对你有帮助,给博主一个免费的点赞以示鼓励,欢迎各位🔎点赞👍评论收藏⭐,谢谢!!!