java 线程安全--Synchronized

2020-04-26  本文已影响0人  superHang

在Java多线程编程当中,提供了以下几种方式来实现线程安全:

Synchronized--阻塞

内部锁(Synchronized)和显式锁(Lock):属于互斥同步方法,是重量级的多线程同步机制,可能会引起上下文切换和线程调度,它同时提供内存可见性、有序性和原子性。

Volatile--非阻塞

volatile:轻量级多线程同步机制,不会引起上下文切换和线程调度。仅提供内存可见性、有序性保证,不提供原子性。

CAS--非阻塞

CAS原子指令:属于非阻塞同步方法,轻量级多线程同步机制,不会引起上下文切换和线程调度。它同时提供内存可见性、有序性和原子化更新保证。单个变量的更新就可以用原子操作

1.Synchronized, 在方法上添加 Synchronized 修饰

还是小华,小明,小航,要到淘宝最全世界最酷炫的LV 小裤裤,但是现在存货只有两条了,自然就是手快有,手慢无啦

    public static void main(String args[]){
        Order order=new Order();
        //启动3个线程,代表他们进行下单
        Thread thread1=new Thread(order,"小华");
        Thread thread2=new Thread(order,"小航");
        Thread thread3=new Thread(order,"小明");
        thread1.start();
        thread2.start();
        thread3.start();
    }

    public static class Order implements Runnable{
        private  int   lvUnderWare=2;  //裤子的库存只有两条了

        @Override
        public  void run() {
                if (lvUnderWare > 0) {
                    System.out.println(Thread.currentThread().getName() + "开始下单买LV的小裤裤," + "订单显示还剩下:" + lvUnderWare + "条");
                    lvUnderWare--;
                    System.out.println(Thread.currentThread().getName() + "下单成功了,买到lv的小裤裤了");
                } else {
                    System.out.println(Thread.currentThread().getName()+"也要购买,但是订单不足了");
                    try {
                        Thread.sleep(1000 * 60 );
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
        }
    }
image.png

可以看到订单显示0条的时候,还能下单成功?出问题了呀,因为小航买的时候,小明也开始买了呀,但是小明下手慢呀,就木得了,所以这个订单出现线程安全得问题了,我们加个同步方法吧

   @Override
        public synchronized void run() {
                if (lvUnderWare > 0) {
                    System.out.println(Thread.currentThread().getName() + "开始下单买LV的小裤裤," + "订单显示还剩下:" + lvUnderWare + "条");
                    lvUnderWare--;
                    System.out.println(Thread.currentThread().getName() + "下单成功了,买到lv的小裤裤了");
                } else {
                    System.out.println(Thread.currentThread().getName()+"也要购买,但是订单不足了");
                    try {
                        Thread.sleep(1000 * 60 );
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
        }
image.png

可以看到这回小明,买不到 了,因为已经卖完了呀

2.Synchronized 修饰代码块

 @Override
        public  void run() {
                if (lvUnderWare > 0) {
                    synchronized (this){
                    System.out.println(Thread.currentThread().getName() + "开始下单买LV的小裤裤," + "订单显示还剩下:" + lvUnderWare + "条");
                    lvUnderWare--;
                    System.out.println(Thread.currentThread().getName() + "下单成功了,买到lv的小裤裤了");
                }
            }
            else {
                System.out.println(Thread.currentThread().getName()+"也要购买,但是订单不足了");
                try {
                    Thread.sleep(1000 * 60 );
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

代表获取当前对象的锁;也可以是类中的一个属性对象,代表获取该属性对象的锁。我得理解就是order 类这个对象得锁,得到得结果也是小明买不到了,也是线程安全得


image.png

3.修饰类

synchronized (Order.class)

@Override
        public  void run() {
            synchronized (Order.class) {
                if (lvUnderWare > 0) {
                    System.out.println(Thread.currentThread().getName() + "开始下单买LV的小裤裤," + "订单显示还剩下:" + lvUnderWare + "条");
                    lvUnderWare--;
                    System.out.println(Thread.currentThread().getName() + "下单成功了,买到lv的小裤裤了");
                } else {
                    System.out.println(Thread.currentThread().getName() + "也要购买,但是订单不足了");
                    try {
                        Thread.sleep(1000 * 60);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }

一样得到得是线程安全的

Volicate

线程在写入volatile变量得时候不会把值缓存在寄存器或者其他地方,而是会把值刷新回主内存中,当其他内存读取该变量得时候,会从主内存中重新获取该值,而不是从当前线程的工作内存中获取值,实际上就是,线程写入了volicate 变量的时候就相当于线程退出同步的代码块,将变量的值写入到主内存中,读取volicate变量的时候就详单与进入同步块,会清空本地内存的变量的值,然后从主内存中获取最新的值

 private  volatile static  int  count=1;
    public static  void main (String [] args) throws InterruptedException {
        int finalI=1;
        for(int i=1;i<=10;i++){
            new Thread(()->{
                count++;
                System.out.println(count);
            }).start();
        }
        Thread.sleep(1000);
        System.out.println("final:"+count);
    }
image.png

可以看到中间的count 的值是线程不安全的,但是最终得到的值永远都是 11
所以使用volicate 我觉得如果是要关注每个线程中间的变量值是不适合的,所以说当写入变量值要依赖当前变量值,这种操作不是原子性的,而volicate不保证原子性的

锁释放

异常自动释放锁
当一个线程执行的代码出现异常时,其所持有的锁会自动释放。

上一篇下一篇

猜你喜欢

热点阅读