ReentrantReadWriteLock——写写互斥（二）

package ReentrantReadWriteLock;

import java.util.concurrent.locks.ReentrantReadWriteLock;

public class Service {

    private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
    
    //写写互斥
    public void write(){
        
        try{
            try{
                lock.writeLock().lock();//写锁
                System.out.println("获得写锁"+Thread.currentThread().getName()+" "+System.currentTimeMillis());
                Thread.sleep(10000);
            }finally{
                lock.writeLock().unlock();//解锁
            }
            
        }catch(Exception e){
            e.printStackTrace();
        }
        
    }
    
    
}

package ReentrantReadWriteLock;

public class ThreadA extends Thread{

    private Service service ;
    
    public ThreadA(Service service){
        super();
        this.service = service;
    }
    
    @Override
    public void run(){
        service.write();
    }
    
    
}

package ReentrantReadWriteLock;

public class ThreadB extends Thread{

private Service service ;
    
    public ThreadB(Service service){
        super();
        this.service = service;
    }
    
    @Override
    public void run(){
        service.write();
    }
    
    
}

package ReentrantReadWriteLock;

public class Run {

    public static void main(String[] args) {
        
        Service service = new Service();
        ThreadA a = new ThreadA(service);
        a.setName("A");
        ThreadB b = new ThreadB(service);
        b.setName("B");
        a.start();
        b.start();
    }
}