JUC 并发编程--12, 使用AtomicInteger 实现一把锁(排队自旋锁), 代码演示

前面使用自旋锁实现了一把锁,(请看第5篇)

volatile 三大特性: 可见性, 不保证原子性, 禁止指令重排

为了解决 volatile不保证原子性的问题, 引入了原子类, AtomicInteger, 底层是使用了 CAS 直接变成汇编指令操作硬件,从而解决了原子性的问题

而 Lock 类的底层实现是 AQS 和CAS,

这里使用 AtomicInteger的特性和自旋锁来实现一把排队自旋锁锁:

  class AtomicLock {

    private AtomicInteger serviceNum = new AtomicInteger();//等待者

    private AtomicInteger ticketNum = new AtomicInteger();//排队号

    public int atomicLock() {

        // 排队号加1

        int myTicketNum = ticketNum.getAndIncrement();

        //只要 排队号和 等待着的号不同,等待者就一直循环,  如果相同,就返回排队号,  这里相当于加锁成功

        while (serviceNum.get() != myTicketNum) {

        }

        System.out.println(Thread.currentThread().getName() + "加锁成功");

        return myTicketNum;

    }

    public void atomicUnlock(int num) {

        // 如果要解锁,就将排队号 +1, 并设置回等待者

        int next = num + 1;

        serviceNum.compareAndSet(num, next);

        System.out.println(Thread.currentThread().getName() + "解锁成功");

    }

    static int num = 0;

    public static void main(String[] args) throws InterruptedException {

        /**

         * 这个锁的缺点是: 如果线程很多, 这么多线程都要操作 同一个Atomicinteger,  且为了保证 各个线程的工作缓存中的数据一致性,

         * 会频繁的 在工作缓存和 主存之间进行通信,,造成系统总线和主存之间繁重的流量, 进而降低系统的性能

         *

         * 但是多处理器系统上，每个进程/线程占用的处理器都在读写同一个变量serviceNum ，每次读写操作都必须在多个处理器缓存之间进行缓存同步，

         * 这会导致繁重的系统总线和内存的流量，大大降低系统整体的性能。

         * 如何解决:  使用  CLH锁和MCS锁

         */

        AtomicLock atomicLock = new AtomicLock();

        for (int i = 0; i < 10; i++) {

            new Thread(() -> {

                int j = atomicLock.atomicLock();

                System.out.println(Thread.currentThread().getName() + "操作开始: num: " + num);

                for (int k = 0; k < 20; k++) {

                    num++;

                }

                System.out.println(Thread.currentThread().getName() + "操作结束: num: " + num);

                atomicLock.atomicUnlock(j);

            },"线程"+i).start();

        }

        TimeUnit.SECONDS.sleep(3);

        System.out.println("最终结果num: "+num);

    }

}

运行结果:

CLH锁和 MCS锁, 这个是目前写的比较好的博客

https://www.jianshu.com/p/1b1b44e84394

巴特西

JUC 并发编程--12, 使用AtomicInteger 实现一把锁(排队自旋锁), 代码演示

最新文章

热门文章