AQS源码探究_02 AQS简介及属性分析

网友投稿 574 2022-05-29

1. 简介

AQS的全称是AbstractQueuedSynchronizer,它的定位是为Java中几乎所有的锁和同步器提供一个基础框架。

AQS是基于FIFO的队列实现的,并且内部维护了一个状态变量state,通过原子更新这个状态变量state即可以实现加锁解锁操作。

2. 主要内部类Node

static final class Node { // 标识一个节点是共享模式 static final Node SHARED = new Node(); // 标识一个节点是互斥模式 static final Node EXCLUSIVE = null; // 标识线程已取消(表示当前节点处于取消状态) static final int CANCELLED = 1; // 标识后继节点需要唤醒(表示当前节点需要唤醒他的后继节点) static final int SIGNAL = -1; // 标识线程等待在一个条件上 static final int CONDITION = -2; // 标识后面的共享锁需要无条件的传播(共享锁需要连续唤醒读的线程) static final int PROPAGATE = -3; // 当前节点保存的线程对应的等待状态(node状态可选值:0,SIGNAL,CANCELLED,CONDITION,PROPAGATE) // waitStatus == 0 默认状态 // waitStatus > 0 取消状态 // waitStatus == -1 表示当前node如果是head节点时,释放锁之后需要唤醒它的后继节点 volatile int waitStatus; // 前一个节点(前驱):用于node构建 FIFO队列~ volatile Node prev; // 后一个节点(后驱):用于node构建 FIFO队列~ volatile Node next; // 当前node节点封装的线程 volatile Thread thread; // 下一个等待在条件上的节点(Condition锁时使用) Node nextWaiter; // 是否是共享模式 final boolean isShared() { return nextWaiter == SHARED; } // 获取前一个节点 final Node predecessor() throws NullPointerException { Node p = prev; if (p == null) throw new NullPointerException(); else return p; } // 节点的构造方法 Node() { // Used to establish initial head or SHARED marker } // 节点的构造方法 Node(Thread thread, Node mode) { // Used by addWaiter // 把共享模式还是互斥模式存储到nextWaiter这个字段里面了 this.nextWaiter = mode; this.thread = thread; } // 节点的构造方法 Node(Thread thread, int waitStatus) { // Used by Condition // 等待的状态,在Condition中使用 this.waitStatus = waitStatus; this.thread = thread; } }

1

2

3

4

5

6

7

8

9

10

11

12

13

14

AQS源码探究_02 AQS简介及属性分析

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

双链表结构,节点中保存着当前线程、前一个节点、后一个节点以及线程的状态等信息。

3. 主要属性

// 队列的头节点: 任何时刻,头结点对应的线程就是当前持锁线程~ private transient volatile Node head; // 队列的尾节点:(阻塞队列不包含头结点head,是从head.next 开始,到 tail 结束,这个区间是阻塞队列~) private transient volatile Node tail; // 控制加锁解锁的状态变量 // 独占模式下:0 表示未加锁状态, >0 表示已加锁状态 private volatile int state;

1

2

3

4

5

6

7

定义了一个状态变量和一个队列,状态变量用来控制加锁解锁,队列用来放置等待的线程。

注意:这几个变量都要使用volatile关键字来修饰,因为是在多线程环境下操作,要保证它们的值修改之后对其它线程立即可见。

这几个变量的修改是直接使用的Unsafe这个类来操作的:

// 获取Unsafe类的实例,注意这种方式仅限于jdk自己使用,普通用户是无法这样调用的 private static final Unsafe unsafe = Unsafe.getUnsafe(); // 状态变量state的偏移量 private static final long stateOffset; // 头节点的偏移量 private static final long headOffset; // 尾节点的偏移量 private static final long tailOffset; // 等待状态的偏移量(Node的属性) private static final long waitStatusOffset; // 下一个节点的偏移量(Node的属性) private static final long nextOffset; static { try { // 获取state的偏移量 stateOffset = unsafe.objectFieldOffset (AbstractQueuedSynchronizer.class.getDeclaredField("state")); // 获取head的偏移量 headOffset = unsafe.objectFieldOffset (AbstractQueuedSynchronizer.class.getDeclaredField("head")); // 获取tail的偏移量 tailOffset = unsafe.objectFieldOffset (AbstractQueuedSynchronizer.class.getDeclaredField("tail")); // 获取waitStatus的偏移量 waitStatusOffset = unsafe.objectFieldOffset (Node.class.getDeclaredField("waitStatus")); // 获取next的偏移量 nextOffset = unsafe.objectFieldOffset (Node.class.getDeclaredField("next")); } catch (Exception ex) { throw new Error(ex); } } // 调用Unsafe的方法原子更新state protected final boolean compareAndSetState(int expect, int update) { return unsafe.compareAndSwapInt(this, stateOffset, expect, update); }

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

4. 父类属性

AQS还用到了其父类AbstractOwnableSynchronizer的一些属性:

// 独占模式下:表示当前持有锁的线程~ private transient Thread exclusiveOwnerThread;

1

2

任务调度 容器

版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:使用Latex制作分享,演讲,Presentation用的Slides,PPT——Beamer教程
下一篇:AI Gallery体验,一键上线模型&发布数据
相关文章