自分で再ロックを実現

再入力できないロックを実現します.

package MyLock;

public class MyLock {
    private boolean isLock;

    public synchronized  void lock(){
        while (isLock){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        isLock = true;
    }

    private synchronized void unlock(){
        if(isLock){
            isLock = false;
            notify();
        }
    }

    static MyLock myLock = new MyLock();

    public static void a(){
        myLock.lock();
        System.out.println("a ");
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        b();
        myLock.unlock();

    }
    public static void b(){
        myLock.lock();
        System.out.println("b ");
        myLock.unlock();
    }
    public static void main(String[] args) {

        new Thread(new Runnable() {
            @Override
            public void run() {
                a();

            }
        }).start();
    }
}

a()メソッドがb()メソッドを呼び出す場合,再入ロックではないため,b()メソッドはロックを取得しようとするが,a()メソッドはロックを保持しても解放されず,永遠の待機に入る.
スレッドの再入不可の問題を解決するために、現在のロックを取得したスレッドがこのロックに数回アクセスしないことを可能にし、スレッドがロックにアクセスした回数を記録し、ロックを解放し、回数が0の場合、ロックを解放する.
コードは次のとおりです.
 

package MyLock;

import java.util.concurrent.atomic.LongAdder;

public class My2Lock {
    private boolean isLock;
    Thread thread;
    LongAdder lockCount = new LongAdder();
    public synchronized  void lock(){
        while (isLock && thread!=null && thread!=Thread.currentThread()){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        isLock = true;
        thread = Thread.currentThread();
        lockCount.increment();
    }

    private synchronized void unlock(){
        if(thread!=null && thread==Thread.currentThread()){
            lockCount.decrement();
            if(lockCount.longValue()==0){
                thread=null;
                isLock = false;
                notify();
            }
        }

    }

    static My2Lock myLock = new My2Lock();

    public static void a(){
        myLock.lock();
        System.out.println("a ");
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        b();
        myLock.unlock();

    }
    public static void b(){
        myLock.lock();
        System.out.println("b ");
        myLock.unlock();
    }
    public static void main(String[] args) {

        new Thread(new Runnable() {
            @Override
            public void run() {
                a();

            }
        }).start();
        /*new Thread(new Runnable() {
            @Override
            public void run() {
                b();

            }
        }).start();*/


    }

}