Java并发机制底层实现原理-原子操作的实现原理

简介: 章节目录原子操作含义相关术语保证多处理器操作原子性的两种方式Java语言层面上实现原子操作原子操作的含义:原子本意是"不能被进一步分割的最小粒子",而原子操作意为,不可中断的一个或一系列操作。

章节目录

  • 原子操作含义
  • 相关术语
  • 保证多处理器操作原子性的两种方式
  • Java语言层面上实现原子操作

原子操作的含义:

原子本意是"不能被进一步分割的最小粒子",而原子操作意为,不可中断的一个或一系列操作。

相关术语

术语名称 英文 解释
缓存行 Cache line 缓存的最小操作单位
比较并交换 Compare and Swap CAS操作需要输入两个数值,一个旧值(期望操作前的值)和一个新值,在操作期间先比较旧值有没有发生变化,如果没有发生变化,才交换成新值,发生变化,表示有多线程竞争,则不交换

保证多处理器操作原子性的两种方式

  • 通过总线锁保证操作共享变量是原子性的
如果多个处理器同事对共享变量进行读改写操作(i++是经典的读改写操作),那
么共享变量就会被多个处理器同时进行操作,这样读改写操作就不是原子性的,操作完之后,共享变量的值会和期望的不一致。
如:
public class IncreaceThread implements Runnable {
    public int i = 1;

    public void run() {
        this.i = ++i;
    }

    public int getI(){
        return this.i;
    }

    public static void main(String[] args) {
        IncreaceThread increaseThread = new IncreaceThread();
        Thread thread1 = new Thread(increaseThread);
        Thread thread2 = new Thread(increaseThread);
        thread1.start();
        thread2.start();
        System.out.println(increaseThread.getI());
    }
}
计算出最终i的值有可能是2,而不是3。
原因可能是多个处理器同时从各自的缓存中读取变量i,分别进行+1操作,然后分别写入到系统内从中。
想要保证改写共享变量的操作是原子的,那就必须保证CPU1读改写共享变量的
时候,CPU2不能操作缓存了该共享变量内存地址的缓存。
处理器使用总线锁来解决这个问题,所谓总线锁,就是处理器提供一个LOCK#信号,当一个处理器在总线上输出此信号时,
其他处理器的请求将被阻塞住,那么该处理器可以独占共享内存。
  • 使用缓存锁保证原子性
第二个机制是通过缓存锁定来保证原子性。
同一时刻,我们只需保证对某个内存地址的操作是原子性即可,但总线锁定把CPU 和内存之间的通信锁住,这使得锁定期间,其他处理器不能操作其他内存地址的数据,所以总线锁的开销比较大。
使用缓存锁定开销会变小,缓存锁定,是指内存区域如果被缓存在处理器缓存行中,并且在Lock操作期间被锁定,那么当它执行锁操作回写到内存时,处理器不在总线上声言LOCK#信号,而是修改内部的内存地址,并允许它的缓存一致性来保证操作的原子性。

Java语言层面上实现原子操作

在Java中通过锁和循环CAS的方式实现原子操作

使用循环CAS实现原子操作

JVM中的CAS操作正式利用了处理器提供的cmpxchg指令实现的,自旋基本思路就是循环进行CAS操作知道成功为止,以下代码实现可一个基于CAS线程安全的计数器方法safeCount 和一个非线程安全的计数器count。

package com.imooc.item;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;

public class Counter {
    private AtomicInteger atomicInteger = new AtomicInteger(0);
    private int i = 0;

    public void safeCount() {
        for (; ; ) {
            int i = atomicInteger.get();
            boolean suc = atomicInteger.compareAndSet(i, ++i);
            if (suc) {
                break;
            }
        }
    }

    //线程计数器
    public void count() {
        i++;
    }

    public static void main(String[] args) {
        final Counter cas = new Counter();
        List<Thread> ts = new ArrayList<Thread>(600);
        long start = System.currentTimeMillis();
        for (int i = 0; i < 100; i++) {
            Thread t = new Thread(new Runnable() {
                @Override
                public void run() {
                    for (int i = 0; i < 10000; i++) {
                        cas.count();
                        cas.safeCount();
                    }
                }
            });
            ts.add(t);
        }

        //开始运行线程
        for (Thread t : ts) {
            t.start();
        }

        //等待所有线程执行完毕
        for (Thread t : ts) {
            try {
                t.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println(cas.i);
        System.out.println(cas.atomicInteger.get());
        System.out.println(System.currentTimeMillis() - start);
    }
}

运行结果如下所示:

996309
1000000
61

CAS实现原子操作的三大问题

  • ABA 问题
因为CAS需要在操作值的时候,检查值有没有发生变化,如果没有发生变化则
更新,但如果一个值原来是A,变成了B,又变成了A,那么使用CAS进行检查时会
发现它的值没有发生变化,但实际上却变了,ABA问题的解决思路就是使用版
本号,在变量前面加上版本号,每次变量更新的时候把版本号加1。
那么A->B->A问题就会变成1A-2B-3A.
  • 循环时间开销大
自旋CAS如果长时间不成功,会给CPU带来非常大的执行开销。常用做法是控制自旋的次数。
  • 只能保证一个共享变量的原子操作
当对一个共享变量执行操作时,我们可以使用循环CAS的方式保证原子操作,
但是对多个共享变量操作时,循环CAS就无法保证操作的原子性,这个时候可
以用锁。

使用锁机制实现原子操作

  • 锁机制保证了只有获得锁的线程才能够 操作锁定的线程共享区域(临界区),
JVM内部实现了很多的锁机制:偏向锁、轻量级锁和互斥锁。其中,除了偏向
锁,JVM实现锁的方式都使用了循环CAS,即当一个线程想进入同步块的时候使
用循环CAS的方式获取锁,当它退出同步块的时候使用循环CAS释放锁。
目录
相关文章
|
3天前
|
安全 Java API
JAVA并发编程JUC包之CAS原理
在JDK 1.5之后,Java API引入了`java.util.concurrent`包(简称JUC包),提供了多种并发工具类,如原子类`AtomicXX`、线程池`Executors`、信号量`Semaphore`、阻塞队列等。这些工具类简化了并发编程的复杂度。原子类`Atomic`尤其重要,它提供了线程安全的变量更新方法,支持整型、长整型、布尔型、数组及对象属性的原子修改。结合`volatile`关键字,可以实现多线程环境下共享变量的安全修改。
|
2天前
|
存储 Java
JAVA并发编程AQS原理剖析
很多小朋友面试时候,面试官考察并发编程部分,都会被问:说一下AQS原理。面对并发编程基础和面试经验,专栏采用通俗简洁无废话无八股文方式,已陆续梳理分享了《一文看懂全部锁机制》、《JUC包之CAS原理》、《volatile核心原理》、《synchronized全能王的原理》,希望可以帮到大家巩固相关核心技术原理。今天我们聊聊AQS....
|
3天前
|
Java 数据库
JAVA并发编程-一文看懂全部锁机制
曾几何时,面试官问:java都有哪些锁?小白,一脸无辜:用过的有synchronized,其他不清楚。面试官:回去等通知! 今天我们庖丁解牛说说,各种锁有什么区别、什么场景可以用,通俗直白的分析,让小白再也不怕面试官八股文拷打。
|
4天前
|
Java 程序员 开发者
Java中的异常处理机制深度解析
本文旨在深入探讨Java中异常处理的核心概念与实际应用,通过剖析异常的本质、分类、捕获及处理方法,揭示其在程序设计中的关键作用。不同于常规摘要,本文将直接切入主题,以简明扼要的方式概述异常处理的重要性及其在Java编程中的应用策略,引导读者快速把握异常处理的精髓。
|
3天前
|
安全 Java 开发者
Java并发编程中的锁机制解析
本文深入探讨了Java中用于管理多线程同步的关键工具——锁机制。通过分析synchronized关键字和ReentrantLock类等核心概念,揭示了它们在构建线程安全应用中的重要性。同时,文章还讨论了锁机制的高级特性,如公平性、类锁和对象锁的区别,以及锁的优化技术如锁粗化和锁消除。此外,指出了在高并发环境下锁竞争可能导致的问题,并提出了减少锁持有时间和使用无锁编程等策略来优化性能的建议。最后,强调了理解和正确使用Java锁机制对于开发高效、可靠并发应用程序的重要性。
13 3
|
4天前
|
Java 编译器 开发者
Java中的异常处理机制:从基础到高级应用
在Java编程中,异常处理是一个至关重要的部分,它帮助开发者处理运行时错误,确保程序的鲁棒性和可靠性。本文将深入探讨Java异常处理的基础和高级应用,包括异常的分类、捕获和处理方法,以及如何使用自定义异常和异常链。通过实际案例,我们将展示如何有效利用Java的异常处理机制来提升代码质量。
|
2天前
|
监控 算法 Java
Java中的内存管理:理解Garbage Collection机制
本文将深入探讨Java编程语言中的内存管理,特别是垃圾回收(Garbage Collection, GC)机制。我们将从基础概念开始,逐步解析垃圾回收的工作原理、不同类型的垃圾回收器以及它们在实际项目中的应用。通过实际案例,读者将能更好地理解Java应用的性能调优技巧及最佳实践。
10 0
|
2天前
|
Java
JAVA并发编程ReentrantLock核心原理剖析
本文介绍了Java并发编程中ReentrantLock的重要性和优势,详细解析了其原理及源码实现。ReentrantLock作为一种可重入锁,弥补了synchronized的不足,如支持公平锁与非公平锁、响应中断等。文章通过源码分析,展示了ReentrantLock如何基于AQS实现公平锁和非公平锁,并解释了两者的具体实现过程。
|
2天前
|
Java 开发者
Java中的异常处理机制:理解与应用
在Java编程中,异常处理是确保程序稳定性和可靠性的关键。本文将深入探讨Java的异常处理机制,包括异常的分类、捕获和处理方法,以及如何有效地使用这些工具来提高代码质量。
|
2天前
|
Java 程序员 开发者
Java中的异常处理机制:从基础到高级应用
在Java编程中,异常处理是确保程序稳定性和可靠性的关键。本文将深入探讨Java异常处理的基本概念、不同类型的异常、常用的异常处理技术以及一些最佳实践。通过阅读本文,您将能够更好地理解和运用Java异常处理机制,提升您的编程技能。
8 0