Java并发编程之美_部分71
需积分: 0 135 浏览量
2022-08-04
12:15:20
上传
评论
收藏 24.78MB PDF 举报
®
仅供才｜商业用途或交流学习使用
第
10
章
Java
并发包中线程同步器原理剖析
I
263
int
nextc
=
c-1;
工 f
(compareAndSetState(c,
nextc))
return
nextc
== O;
如上代码首先获取当前状态值（计数器值）
。
代码
Cl
）判断如果当前状态值为
0
则直
接返回
fa
l
se
，从而
countDown
(
）方法直接返回：否则执行代码。）使用
CAS
将计数器
值减
1,
CAS
失败则循环重试，否则如果当前计数器值为
0
则返回
true
，返回
true
说明是
最后
一
个线程调用的
countdown
方法，那么该线程除了让计数器值减
l
外，还需要唤醒因
调用
Co
untDownLatch
的
await
方法而被阻塞的线程，具体是调用
AQS
的
doReleaseShared
方法来激活阻塞的线程。这里代码
Cl
）貌似是多余的，其实不然，之所以添加代码
Cl)
是为了防止当计数器值为
0
后，其他线程又调用了
co
untDo
wn
方法，如果没有代码
C
I ) '
状态值就可能会变成负数。
4. long
getCount
（）方法
获取当前计数器的值，也就是
AQS
的
s
tate
的
值，一般在测试时使用该方法。下面看
下代码
。
publ
工
c
long
getCouηt
()
{
retur
口
sync.getCount();
int
getCount() {
return
getState
();
由如上代码可知，在其内部还是调用了
AQS
的
ge
tState
方法来获取
state
的值（计数
器当前值）。
10.1.3
小结
本节首先介绍了
Co
untDownLatch
的
使用，相比使用
jo
in
方法来实现线程间
同
步，
前者更具有灵活性和方便性
。另
外还介绍了
CountDownLatch
的原理，
CountDownLatch
是使用
AQS
实现的。使用
AQS
的状态变量来存放计数器
的值
。首先在
初始化
CountDownLatch
时设置状态值（计数器值），当多个线程调用
countdown
方法时实际是原
子性递减
AQS
的状态值。当线程调用
awa
it
方法后当前线程会被放入
AQS
的阻塞队列等
剩余48页未读，继续阅读
评论0