synchronized与ReentrantLock实现共享资源的消费

2018-08-17 09:40:54来源：博客园阅读 ()

主方法

public class synchronizedTest {
    public static void main(String[] args) {
        long startTime = System.currentTimeMillis();  
        TicketSystem ticketSystem=new TicketSystem();
        Thread  t1=new Thread(ticketSystem);
        Thread  t2=new Thread(ticketSystem);
        Thread  t3=new Thread(ticketSystem);
        Thread  t4=new Thread(ticketSystem);
        t1.setName("1号售票点");
        t2.setName("2号售票点");
        t3.setName("3号售票点");
        t4.setName("4号售票点");
        t1.start();
        t2.start();
        t3.start();
        t4.start();
        while (true) {
            if(ticketSystem.getTicKetNumber()<=0){
                long endTime = System.currentTimeMillis();  
                float seconds = (endTime - startTime) / 1000F;  
                System.out.println(Float.toString(seconds) + " seconds."); 
                break;
            }
        }
    }
}

synchronized线程方法1：

public class TicketSystem implements Runnable {

    private static volatile int ticketNumber = 900;


    public int getTicKetNumber() {
        return this.ticketNumber;
    }

    @Override
    public synchronized  void run() {
        while (true) {
            if (ticketNumber <= 0) {
                break;
            } else {
                System.out.println(Thread.currentThread().getName() + "卖了最后第" + ticketNumber + "票");
                ticketNumber--;
            }
        }
    }

}

ReentrantLock线程方法2：

public class TicketSystem implements Runnable {

    private static volatile int ticketNumber = 900;

    private ReentrantLock lock = new ReentrantLock();

    public int getTicKetNumber() {
        return this.ticketNumber;
    }

    @Override
    public void run() {
        while (true) {
            lock.lock();
            if (ticketNumber <= 0) {
                break;
            } else {
                System.out.println(Thread.currentThread().getName() + "卖了最后第" + ticketNumber + "票");
                ticketNumber--;
            }
            lock.unlock();
        }
    }

}