java自定义lock锁

实现原理

Java Lock底层是用 AQS + Cas + LockSupport实现的。

思路
使用原子类 AtomicInteger 定义锁的状态
当一个线程修改状态之后，其他线程都处于等待状态
当线程释放锁之后，其他线程被唤醒，重新竞争锁资源

核心代码


import java.util.concurrent.ConcurrentLinkedDeque;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.LockSupport;public class CustomLock {// 0 上锁 1 释放锁private AtomicInteger lockState = new AtomicInteger(0);// 当前获得锁的线程private Thread getLockThread = null;// 阻塞线程队列private ConcurrentLinkedDeque<Thread> threadList = new ConcurrentLinkedDeque();public void lock(){acquire();}public boolean acquire(){for(;;) {if(compareAndSet(0, 1)) {// 获取锁成功getLockThread = Thread.currentThread();return true;}// 获取锁失败Thread thread = Thread.currentThread();threadList.add(thread);LockSupport.park();}}public boolean compareAndSet(int expect, int update){return lockState.compareAndSet(expect, update);}public boolean unLock(){if(getLockThread == null) {return false;}if(Thread.currentThread() == getLockThread) {boolean result = compareAndSet(1, 0);if(result) {// 公平锁唤醒Thread first = threadList.getFirst();LockSupport.unpark(first);// 非公平锁// 非公平锁的唤醒需要 使用循环把列表中的所有的 线程全部唤醒}return true;}return false;}
}

测试demo

 public static void main(String[] args) throws InterruptedException {CustomLock customLock = new CustomLock();customLock.lock();new Thread(() -> {System.out.println("start");customLock.lock();System.out.println("end");}).start();Thread.sleep(1000);customLock.unLock();System.out.println("hhh");}

java自定义lock锁相关推荐

java中Lock锁的应用简介
java中Lock锁的应用简介整体描述方法介绍 1. void lock() 2. boolean tryLock() 3. boolean tryLock(long timeout, TimeU ...
java:lock锁
synchronized锁效率比较低,不方便扩展,不能自定义.于是从jdk1.5之后,就引入了lock锁. lock可以手动上锁,手动释放锁,灵活性很高. Lock lock = new Reentr ...
Java并发编程—JUC的Lock锁
一.Lock (JUC锁) JUC 锁位于java.util.concurrent.locks包下,为锁和等待条件提供一个框架,它不同于内置同步和监视器. CountDownLatch,CyclicB ...
【java线程】锁机制：synchronized、Lock、Condition
[Java线程]锁机制:synchronized.Lock.Condition 原创 2013年08月14日 17:15:55 标签:Java /多线程 74967 http://www.infoq. ...
java 中lock,java中lock获取锁的四种方法
在java接口中会存放着许多方法,方便线程使用时的直接调用.对于lock接口大家都不陌生,我们已经初步对概念进行了理解.那么在获取锁的方法上想必还不是很清楚.下面我们就lock获取锁的四种方法分别进行 ...
java 多线程串行加锁_java多线程 synchronized 与lock锁实现线程安全
如果有多个线程在同时运行,而这些线程可能会同时运行这段代码.程序每次运行结果和单线程运行的结果是一样的,而且其他的变量的值也和预期的是一样的,就是线程安全的. 通过卖火车票的例子火车站要卖票,我们 ...
java多线程安全解决方案_java常用知识:多线程安全问题的解决方法-Lock锁
jdk1.5后出现的两个方法: void Lock() void unlock() 使用步骤: 1.在成员位置创建一个ReentrantLock对象 2.在可能出现安全问题的代码前调用Lock接口中 ...
java 代码锁_Java中的Lock锁
Lock锁介绍: 在java中可以使用 synchronized 来实现多线程下对象的同步访问,为了获得更加灵活使用场景.高效的性能,java还提供了Lock接口及其实现类ReentrantLock和 ...
java并发,同步synchronize和lock锁的使用方法和注意,死锁案例分析
1.什么是线程安全问题多个线程同时共享同一个全局变量或者静态变量的时候,某个线程的写操作,可能会影响到其他线程操作这个变量.所有线程读一个变量不会产生线程安全问题. 实际场景就是火车站买票问题:剩余 ...

java自定义lock锁

实现原理

核心代码

测试demo

java自定义lock锁相关推荐

最新文章

热门文章