ReentrantLock简单实现2

ReentrantLock：

　　

/**
 *    ReentrantLock测试逻辑类
 */
public class MyService {
    private Lock lock = new ReentrantLock();//获取锁对象
    
    public void methodA() {
        try {
            lock.lock();
            System.out.println("methodA:----begin" + Thread.currentThread().getName() + "----" + System.currentTimeMillis());
            Thread.sleep(2000);
            System.out.println("methodA:----end" + Thread.currentThread().getName() + "----" + System.currentTimeMillis());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally {
            lock.unlock();
        }
    }
    
    public void methodB() {
        try {
            lock.lock();
            System.out.println("methodB:----begin" + Thread.currentThread().getName() + "----" + System.currentTimeMillis());
            Thread.sleep(2000);
            System.out.println("methodB:----end" + Thread.currentThread().getName() + "----" + System.currentTimeMillis());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally {
            lock.unlock();
        }
    }
}

/**
 *    线程A
 */
public class ThreadA extends Thread {
    
    private MyService service;
    
    public ThreadA(MyService service) {
        this.service = service;
    }
    
    @Override
    public void run() {
        service.methodA();
    }
}

/**
 *    线程AA
 */
public class ThreadAA extends Thread {
    
    private MyService service;
    
    public ThreadAA(MyService service) {
        this.service = service;
    }
    
    @Override
    public void run() {
        service.methodA();
    }
}

/**
 *    线程B
 */
public class ThreadB extends Thread {
    
    private MyService service;
    
    public ThreadB(MyService service) {
        this.service = service;
    }
    
    @Override
    public void run() {
        service.methodB();
    }
}

/**
 *    线程BB
 */
public class ThreadBB extends Thread {
    
    private MyService service;
    
    public ThreadBB(MyService service) {
        this.service = service;
    }
    
    @Override
    public void run() {
        service.methodB();
    }
}

/**
 *    测试类
 */
public class Run {

    public static void main(String[] args) {
        MyService service = new MyService();
        
        ThreadA a = new ThreadA(service);
        a.setName("A");
        a.start();
        ThreadAA aa = new ThreadAA(service);
        aa.setName("AA");
        aa.start();

        ThreadB b = new ThreadB(service);
        b.setName("B");
        b.start();
        ThreadBB bb = new ThreadBB(service);
        bb.setName("BB");
        bb.start();
    }
}

运行结果如下：