赞
踩
目录
线程的状态是一个枚举类型 Thread.State
- public static void main(String[] args) {
- for (Thread.State state : Thread.State.values()) {
- System.out.println(state);
- }
- }
状态:
- NEW (新建状态):系统中的线程还没创建出来,还只是个对象
- RUNNABLE(就绪状态):就绪状态
- 准备好了,随时可以去CPU运行
- 调用了start(),正在CPU上运行
- BLOCKED(阻塞状态):线程暂停执行,阻塞中
- WAITING(等待状态):线程暂停执行(wait()),等待中
- TIMED_WAITING(计时等待状态):线程暂停执行(sleep(),join(),wait()),计时等待中
- TERMINATED(终止状态):线程执行结束
线程安全:如果多线程环境下代码运行的结果是符合我们预期的,即在单线程环境应该的结果,则说这个程序是线程安全的。
线程不安全:多线程同时访问共享资源时,无序的调度,导致执行顺序的变化,结果就出现差错;
本质原因:线程在系统中调度时无序的/随机的 —— 抢占式执行
1. 抢占式执行
2. 多个线程同时修改 共享资源
- 一个线程修改同一个变量 —>安全
- 多个线程读取同一个变量 —>安全
- 多个线程修改同一个变量 —>不安全
3. 修改操作,不是原子的(不可分割的)
- 修改操作分为了几部分执行(多条CPU指令),加载到系统中,线程调用时无序的,会将这些和其他线程调用的指令进行混淆执行
4. 内存可见性,引起的线程不安全
5. 指令重排序,引起的线程不安全
图演示
1.2.3
两个线程各执行1w次,但是共享值依不是 2w,
原因是 同时修改,抢占执行,操作不是原子性;
- class Counter{
- //计数
- public int count = 0;
- void add(){
- count++;
- }
- }
- public class Test {
- public static void main(String[] args) throws InterruptedException {
- Counter counter = new Counter();
- //创建两个线程,分别对count 进行 1w次
- Thread thread1 = new Thread(()->{
- for (int i = 0; i < 10000; i++) {
- counter.add();
- }
- });
- Thread thread2 = new Thread(()->{
- for (int i = 0; i < 10000; i++) {
- counter.add();
- }
- });
- //启动线程
- thread1.start();;
- thread2.start();
- //等待线程
- thread1.join();
- thread2.join();
- //打印counter
- //线程安全/单线程 情况下 应该是2w
- System.out.println(counter.count);
- //14260、13643、12677、15447....
- }
- }
4.5
输入后,依旧运行,造成的原因是 共享值未能修改,指令重排序,优化
- public class Test {
- public static int falg = 0;
- public static void main(String[] args) {
- Thread thread1 = new Thread(()->{
- //
- while (falg == 0){
- //空 持续执行
- }
- System.out.println("thread1 执行结束");
- });
- Thread thread2 = new Thread(()->{
- Scanner scanner = new Scanner(System.in);
- //输入一个数,终止 thread1
- System.out.println("请输入一个非0整数:");
- falg = scanner.nextInt();
- });
- thread1.start();
- thread2.start();
- }
- }
原子性指一个操作要么完全执行,要么完全不执行,不能被其他操作中断或干扰。
共享资源中add()中操作可以 大致分为
- 变量加载:从内存读取变量到CPU寄存器中
- 变量增加:将CPU寄存器中的值+1
- 变量保存:将寄存器中的值读取到内存中
这是一个操作,分为三步实现,在多线程中,想要实现线程安全,就要保证原子性;
如果原子性等不到保证,就会造成变量读取、增加、保存的混乱,造成错误结果
可见性:一个线程对共享变量值的修改,能及时地被其他线程看到
Java 内存模型 (JMM): Java虚拟机规范中定义了Java内存模型.
主内存:线程之间的共享变量存在
工作内存:线程自己拥有的内存,操作使用内存
读取:先把主内存中共享变量读取拷贝到工作内存,再从工作内存中修改数据
修改:先修改工作内存中的副本, 再同步回主内存.
可见性:
当线程A修改类共享变量X,线程B读取的X也会新值
代码的执行顺序不一定是 书写时的顺序
书写:
- 下楼,拿外卖
- 回宿舍,
- 下楼,取快递
在单线程下,JVM,CPU指令集会对其进行优化 ,按 1->3->2 执行;这就是指令重排序
但在多线程,执行程度高,优化后的代码不一定是自己想要的值,
- synchronized 关键字可以用于 方法和代码块中,用于保护共享资源的访问;
- 可以确保同一时间只有一个线程可以访问共享资源,从而实现原子性操作
- synchronized用的锁是存在Java对象头里的。
1. 原子性:synchronized关键字可以确保被它修饰的代码块或方法在同一时刻只能由一个线程执行,保证了代码的原子性。
2. 可见性:synchronized关键字可以保证一个线程在获取锁时,它所在的线程工作内存中的变量值是最新的,而不是缓存中的旧值,这保证了线程之间的可见性。
3. 互斥性:synchronized关键字可以保证同一时刻只有一个线程持有锁,其他线程进入阻塞等待,必须等待锁的释放才能获取锁,从而保证了线程之间的互斥性。
4. 重入性:synchronized关键字是可重入的,也就是说,如果一个线程已经持有了某个对象的锁,那么它再次进入该对象的synchronized代码块时,仍然可以获得该对象的锁,而不会被自己所持有的锁所阻塞。
核心操作:
- 加锁:就是获取锁,使当前线程可以独占同步资源进行操作,防止其他线程同时修改统一资源,进入synchronized修饰的方法和代码块中,就会触发 加锁
- 解锁:就是释放锁,使得其他线程可以获取锁并访问同步资源,出synchronized修饰的方法和代码块中,就触发 解锁
当一个线程 执行到一个synchronized修饰的代码块或者方法时,首先会尝试获取对象的锁,如果该对象的锁已经被其他线程获取,那么当前线程就会被阻塞,直到其他线程释放了该对象的锁;
对于 锁的颗粒不同 分为两种:
加锁主要为了区别是否是同一个对象
1、 对象锁
对象锁:当synchronized 修饰一个对象时,该对象就会成为同步锁
- 修饰代码块:(this)指定当前对象,锁该类的实例对象
- 修饰普通方法:锁该类的实例对象
- class Counter{
- //计数
- public int count = 0;
- public void add(){
- //代码块 对当前对象
- synchronized (this){
- count++;
- }
- }
- }
或 创建个 私有Object类锁对象,用于锁的同步控制;
- class Counter{
- //计数
- public int count = 0;
- //私有锁对象
- private Object lock = new Object();
- public void add(){
- //代码块 对当前锁对象
- synchronized (lock){
- count++;
- }
- }
- }
方法;
- class Counter{
- //计数
- public int count = 0;
- //修饰普通方法 当前对象
- public synchronized void add(){
- count++;
- }
- }
2、 类锁
类锁:当synchronized 修饰一个静态方法或代码块时,该类就成为同步锁;
- 修饰代码块:(类名.class)指定类,锁该类对象
- 修饰静态方法:锁该类对象
- class Counter{
- //计数
- public int count = 0;
- public void add(){
- //代码块 对该类加锁
- synchronized (Counter.class){
- count++;
- }
- }
- }
方法
- class Counter{
- //计数
- public int count = 0;
- //修饰静态方法 加锁该类
- public synchronized static void add(){
- count++;
- }
- }
- class Quit{
- public int falg = 0;
- }
- public class Test {
- public static void main(String[] args) {
- Quit qu = new Quit();
- Thread thread1 = new Thread(()->{
- //持续执行
- while (true){
- //
- synchronized (qu){
- if (qu.falg != 0){
- System.out.println("thread1 执行结束");
- break;
- }
- }
- }
- });
- Thread thread2 = new Thread(()->{
- Scanner scanner = new Scanner(System.in);
- //输入一个数,终止 thread1
- System.out.println("请输入一个非0整数:");
- qu.falg = scanner.nextInt();
- });
- thread1.start();
- thread2.start();
- }
- }
注意:无论如何,加锁都可能导致阻塞,对于代码的效率肯定会有影响
特性:
- 可见性:当一个线程修改了volatile变量的值,其他线程能够立即看到该变量的最新值。
- 原子性:对于单个volatile变量的读/写操作是具有原子性的,但是对于多个操作的复合操作则不具有原子性。
- 顺序性:对于volatile变量的读/写操作会按照程序的顺序执行,不能被重排序。
volatile 修饰的共享变量, 能够保证 "内存可见性".
- 未加 volatile 修饰共享变量,线程1对代码进行了优化,不再读取操作,线程2修改共享变量未被线程1读取
- 加上volatile 修饰共享变量,线程2修改共享变量会被线程1及时读取,终止线程
- public class Test {
- //保证 共享变量falg 内存可见性
- public volatile static int falg = 0;
- public static void main(String[] args) {
- Thread thread1 = new Thread(()->{
- //
- while (falg == 0){
- //空 持续执行
- }
- System.out.println("thread1 执行结束");
- });
- Thread thread2 = new Thread(()->{
- Scanner scanner = new Scanner(System.in);
- //输入一个数,终止 thread1
- System.out.println("请输入一个非0整数:");
- falg = scanner.nextInt();
- });
- thread1.start();
- thread2.start();
- }
- }
- ***************
- 请输入一个非0整数:
- 1
- thread1 执行结束
- ***************
volatile 使用 针对单个变量被一个线程读,一个线程写;对于多个线程的符合操作不具有原子性;
- volatile 禁止对 修饰变量的读/写操作 指令的重排序;
- 任何对 volatile 变量的写入操作都会先于后续的读取操作执行。这样就保证了在多线程环境下,对共享变量的修改能够及时被其他线程看到,从而保证了程序的正确性。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。