LQW_home 2021-07-01 14:28 采纳率: 91.3%
浏览 32
已结题

自己写的一个Lock 是否能锁住,有什么地方需要优化 ???

代码如下

import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.LockSupport;

public class MyLock {
    //用来表示当前线程是否获取锁 0 无锁 1 有锁
//    private volatile int state;
    private volatile static AtomicInteger state = new AtomicInteger(0);

    private Thread ownerThread;

    private volatile Queue<Thread> queue = new LinkedBlockingQueue<>();


    public void lock(){
        //如果当前state为0 则可以将state和当前线程绑定
        Thread thread = Thread.currentThread();
        if(state.compareAndSet(0,1)){
            ownerThread = thread;
        }else{
            for (;;){
                //挂起前 尝试再次获取
                if(state.compareAndSet(0,1)){
                    ownerThread = thread;
                    return;
                }

                if(queue.add(thread)){
                    //挂起
                    LockSupport.unpark(thread);
                    LockSupport.park();
                }

            }
        }
    }

    /**
     * 解锁
     */
    public void unlock(){
        if(state.compareAndSet(1,0)){
            ownerThread = null;//help GC
            Thread peek = queue.peek();
            if(peek != null){
                Thread head = queue.poll();
                LockSupport.unpark(head);
            }
        }

    }

}
  • 写回答

1条回答 默认 最新

  • 纯白微风<alert> 2021-07-01 17:28
    关注

    不可重入,你试试同一个线程连续获取锁的场景,而且你的队列会无限增长

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 系统已结题 3月15日
  • 已采纳回答 3月7日

悬赏问题

  • ¥20 关于#硬件工程#的问题,请各位专家解答!
  • ¥15 关于#matlab#的问题:期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707,使系统具有较小的超调量
  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 截图中的mathematics程序转换成matlab
  • ¥15 动力学代码报错,维度不匹配
  • ¥15 Power query添加列问题
  • ¥50 Kubernetes&Fission&Eleasticsearch
  • ¥15 報錯:Person is not mapped,如何解決?
  • ¥15 c++头文件不能识别CDialog
  • ¥15 Excel发现不可读取的内容