6 Java多线程：锁与AQS（下）( 二 ) _生活百科

然后再运行测试：
/** * 实现Lock接口方法并运行排他锁测试 * * @author 湘王 */public class MyExclusiveLockTester {// 用自定义AQS独占锁实现private Lock lock = new MyExclusiveLock();private int value;public int accmulator() {lock.lock();try {++value;} finally {lock.unlock();}return value;}public static void main(String[] args) throws InterruptedException {MyExclusiveLockTester test = new MyExclusiveLockTester();for (int i = 0; i < 5; i++) {new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 5; i++) {System.out.println(test.accmulator());}}}).start();}}}可以看到，结果无论怎么样都不会再重复了。
这个只是简单的累加，接下来用AQS来实现一个实际的生活场景。比如周末带女票或男票去步行街吃饭，这时候人特别多，需要摇号，而且一次只能进去三张号（不按人头算，按叫到的号来算），该怎么实现呢？
可以顺着这个思路：摇号机虽有很多号，但它本质上是个共享资源，很多人可以共享，但是每次共享的数量有限。这其实就是个可以指定数量的共享锁而已。
既然有了思路，那接下来就好办了。
/** * 利用AQS实现自定义共享锁 * * @author 湘王 */public class MyShareLock implements Lock {@Overridepublic void lock() {}@Overridepublic void lockInterruptibly() throws InterruptedException {}@Overridepublic boolean tryLock() {return false;}@Overridepublic boolean tryLock(long time, TimeUnit unit) throws InterruptedException {return false;}@Overridepublic void unlock() {}@Overridepublic Condition newCondition() {return null;}}还是一样实现Lock接口，但这次是用AQS实现共享锁。
/** * 内部类继承AQS实现共享锁 * */private static class SyncHelper extends AbstractQueuedSynchronizer {private static final long serialVersionUID = -7357716912664213942L;/*** count表示允许几个线程能同时获得锁*/public SyncHelper(int count) {if (count <= 0) {throw new IllegalArgumentException("锁资源数量必须大于0");}// 设置资源总数setState(count);}/*** 一次允许多少个线程进来，允许数量的线程都能拿到锁，其他的线程进入队列*/@Overrideprotected int tryAcquireShared(int acquires) {// 自旋for (;;) {int state = getState();int remain = state - acquires;// 判断剩余锁资源是否已小于0或者CAS执行是否成功if (remain < 0 || compareAndSetState(state, remain)) {return remain;}}}/*** 锁资源的获取和释放要一一对应*/@Overrideprotected boolean tryReleaseShared(int releases) {// 自旋for (;;) {// 获取当前stateint current = getState();// 释放状态state增加releasesint next = current + releases;if (next < current) {// 溢出throw new Error("Maximum permit count exceeded");}// 通过CAS更新state的值// 这里不能用setState()if (compareAndSetState(current, next)) {return true;}}}protected Condition newCondition() {return new ConditionObject();}}然后再来改造之前实现的接口：
/** * 利用AQS实现自定义共享锁 * * @author 湘王 */public class MyShareLock implements Lock {public static int count;private final SyncHelper synchepler = new SyncHelper(count);@Overridepublic void lock() {synchepler.acquireShared(1);}@Overridepublic void lockInterruptibly() throws InterruptedException {synchepler.acquireSharedInterruptibly(1);}@Overridepublic boolean tryLock() {return synchepler.tryAcquireShared(1) > 0;}@Overridepublic boolean tryLock(long time, TimeUnit unit) throws InterruptedException {return synchepler.tryAcquireSharedNanos(1, unit.toNanos(time));}@Overridepublic void unlock() {synchepler.releaseShared(1);}@Overridepublic Condition newCondition() {return synchepler.newCondition();}/*** 内部类继承AQS实现共享锁**/private static class SyncHelper extends AbstractQueuedSynchronizer {private static final long serialVersionUID = -7357716912664213942L;/*** count表示允许几个线程能同时获得锁*/public SyncHelper(int count) {if (count <= 0) {throw new IllegalArgumentException("锁资源数量必须大于0");}// 设置资源总数setState(count);}/*** 一次允许多少个线程进来，允许数量的线程都能拿到锁，其他的线程进入队列*/@Overrideprotected int tryAcquireShared(int acquires) {// 自旋for (;;) {int state = getState();int remain = state - acquires;// 判断剩余锁资源是否已小于0或者CAS执行是否成功if (remain < 0 || compareAndSetState(state, remain)) {return remain;}}}/*** 锁资源的获取和释放要一一对应*/@Overrideprotected boolean tryReleaseShared(int releases) {// 自旋for (;;) {// 获取当前stateint current = getState();// 释放状态state增加releasesint next = current + releases;if (next < current) {// 溢出throw new Error("Maximum permit count exceeded");}// 通过CAS更新state的值// 这里不能用setState()if (compareAndSetState(current, next)) {return true;}}}protected Condition newCondition() {return new ConditionObject();}}}

6 Java多线程：锁与AQS（下）( 二 )

推荐阅读

太原异地就医医保是怎么报销的？

爸爸去哪第几集是在雪乡拍的

2023广交会参观证多少钱办理 2023广交会参观证多少钱？

完美伪装从不将真实性格显于人前的生肖？

广西玉林迪迪校外托管服务有限公司_工商信用信息_经营范围期限状态_法人_地址_注册资本_怎么样

随身WiFi使用教程 lblink随身wifi怎么用

40周年结婚是什么婚姻，四十一年是什么婚

股价跌破净资产怎么看股票价格跌破净资产是什么情况

妃嫔等级妃嫔等级清朝

3月17日起北京云蒙山风景区恢复开园公告

正婚姻什么意思是什么意思是什么生肖，结婚是代表什么生肖？

吃柚子的方法视频柚子的养殖方法视频

甲减能喝栀子花茶吗

椭圆、齿状叶片是什么植物

广州唯品会品牌怎么样？

黑潮之上氪金严重吗-平民氪金攻略热门推荐

抗击疫情的小故事简短抗击疫情的小故事简短20字

如何顺利度过试用期如何度过工作试用期

关于王晓芗简述王晓芗

2022深圳生育保险报销流程及资料