浅聊多线程

📅 2026/7/17 23:57:39
浅聊多线程
话题一为什么要有多线程单线程只是单地将代码自上而下地运行如果程序阻塞或者耗时整个就卡住了多线程可以同时运行多段代码块解决了阻塞io问题同时可以将内存的性能充分释放提高了响应速率使得用户的使用体验更好不至于出现卡顿。话题二进程与线程的区别。进程是内存分配的最小单元线程是cpu分配的最小单元。在一个进程中至少包含了一个主线程并且在同一进程内所有线程共享资源。进程的的创建和切换开销大线程的创建和切换的开销相对轻量级但是由于cpu多核发展受限后来又发明了线程池。话题三线程的五大生命周期。新建new通过new thread 创建线程对象操作系统中还未创建真实线程不分配资源。就绪Runnable)调用 start后进入该状态其中又分两种情况1.就绪线程已经准备好了等待cpu分配时间片2.运行中线程抢到了cpu时间片执行run) 方法阻塞Blocked线程等待同步锁时进入阻塞等待Waiting主动无限的等不占用cpu需要其他线程主动唤醒也可计时等待 Timed_Waiting )终止(Terminated)run()正常执行完/异常终止线程结束资源回收无法再次启动。话题四并发与并行。并发多任务交替执行单核cpu即可并行多任务同时进行(需要有多核cpu话题五线程的创建方法。1.继承Thread类class MyThread extends Thread { Override public void run() { System.out.println(线程执行); } }2.实现runnable接口class MyRun implements Runnable { Override public void run() { System.out.println(Runnable 线程); } }3.匿名内部类lambda表达式Thread t new Thread(()-{ });话题六线程安全问题。1.线程安全是什么线程处理的数据是共享可变的多线程同时进行可能引起数据竞争。2.线程不安全的核心共享变量非原子操作指令重排和可见性问题3.解决方案同步锁synchronized原子类解决原子问题volatile解决可见性问题话题七线程池1.使用线程池的原因减少线程创建销毁的开销控制数量以及任务统一管理避免OOM内存溢出问题2.线程池核心参数1.核心线程数corePoolSize线程池常驻线程数即使空闲也不会被回收长期处理常规任务2.最大线程数maximumPoolSize线程池允许创建的最大线程总数任务激增时扩容3.空闲存活时间keepAliveTime非核心线程的空闲超时时间超时无任务则被回收4.任务队列workQueue存储待执行任务的阻塞队列核心线程满负载后任务进入队列5.拒绝策略handler线程数和队列均满负载时处理超额任务的策略。3.常用的线程池1.固定线程池FixedThreadPool核心线程数最大线程数线程数量固定适合负载稳定的批量任务2.缓存线程池CachedThreadPool无核心线程、最大线程数无限线程空闲自动回收适合短期、大量瞬时任务3.定时线程池ScheduledThreadPool支持延时、周期性执行任务适合定时巡检、定时统计场景4.自定义线程池ThreadPoolExecutor手动配置所有参数适配业务场景参数可控、无隐患企业开发唯一推荐。线程池开发规范与避坑1.禁止使用Executors工具类创建线程池原生线程池存在队列无界、线程数无限等问题极易引发OOM内存溢出2.必须自定义线程池根据业务QPS、任务耗时合理配置核心参数限制最大并发数3.拒绝策略按需选择核心业务使用自定义降级策略非核心业务可丢弃、告警4.必须处理任务异常线程池任务异常会静默消失导致业务无响应、问题难排查需全局捕获异常5.合理设置线程池名称方便日志排查、线程堆栈定位问题。话题八多线程开发中遇见的常见问题1.死锁问题四大要素不可少1互斥条件 2请求保持 3不可剥夺 4: 循环等待)public static void main(String[] args) throws InterruptedException { Object locker1 new Object(); Object locker2 new Object(); Object locker3 new Object(); Thread t1 new Thread(()-{ for(int i 0;i10;i){ synchronized (locker1){ try { locker1.wait(); System.out.print(A); synchronized (locker2){ locker2.notify(); } } catch (InterruptedException e) { throw new RuntimeException(e); } } } }); Thread t2 new Thread(()-{ for(int i 0;i10;i){ synchronized (locker2){ try { locker2.wait(); System.out.print(B); synchronized (locker3){ locker3.notify(); } } catch (InterruptedException e) { throw new RuntimeException(e); } } } }); Thread t3 new Thread(()-{ for(int i 0;i10;i){ synchronized (locker3){ try { locker3.wait(); System.out.println(C); synchronized (locker1){ locker1.notify(); } } catch (InterruptedException e) { throw new RuntimeException(e); } } } }); t1.start(); t2.start(); t3.start(); //先确保所有线程都执行到了wait,才能按照上述逻辑执行有两种方法1sleep 2用scanner阻塞 Thread.sleep(1000); synchronized (locker1) { locker1.notify(); } } }2.线程虚假唤醒private static volatile SingletonLazy instance null; private static Object locker new Object(); public static SingletonLazy getInstance() { //线程 A、线程 B 同时执行 getInstance() //此时 instance null两个线程都通过外层 if(instancenull) 判断 //A 先抢到同步锁进入代码块创建对象释放锁 //B 阻塞完拿到锁直接执行 new又创建了第二个对象 //最终出现两个不同实例单例失效。 // 内层 if 就是为了解决这个场景线程 B 拿到锁后再检查一次 instance发现已经不为 null直接跳过创建。 if(instance null) { synchronized (locker) { if (instance null) { instance new SingletonLazy(); } } } return instance; } private SingletonLazy(){ } } public class Demo28 { public static void main(String[] args) { Singleton t1 Singleton.getInstance(); Singleton t2 Singleton.getInstance(); System.out.print(t1 t2); } }本文仅限个人拙见希望大家能够帮我指出漏洞以及那些没学到的知识谢谢