package com.hencoder.a17_thread_interaction;

/**
 *  讀寫鎖。
 *     ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
 *     Lock readLock = lock.readLock();
 *     Lock writeLock = lock.writeLock();
 *
 */
public class WaitDemo implements TestDemo {
    private String sharedString;

    private int x=0;
    private int y=0;

    /**
     * synchronized 關(guān)鍵字是鎖定當(dāng)前的對象。
     * 被synchronized包括的代碼塊將會是一個原子性的操作，中間不會被打斷
     */
    public synchronized void add(){
        //x++ 在cpu中是分為以下兩個步驟來執(zhí)行的
        //int tmep = x + 1;
        //x = temp;
        x++;
        y++;
    }

    public void sub(){
        synchronized (this){//這個 等價于 直接在方法上面加synchronized 關(guān)鍵字
            x--;
            y--;
        }
    }


    private synchronized void initString() {
        sharedString = "rengwuxian";
        notifyAll();//必須寫在synchronized方法里
    }

    private synchronized void printString() {
        //wait()方法 會暫時丟掉synchronized鎖。直到InterruptedException或者 notify
        while (sharedString == null) {//要用while因為 Thread.interrupted()也會喚醒wait();
            try {
                wait();//必須寫在synchronized方法里，因為wait要釋放鎖
            } catch (InterruptedException e) {//如果線程被調(diào)用了Thread.interrupted()方法 則會拋出這個異常
                e.printStackTrace();
            }
        }
        System.out.println("String: " + sharedString);
    }

    @Override
    public void runTest() {
        final Thread thread1 = new Thread() {
            @Override
            public void run() {
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                printString();
            }
        };
        thread1.start();
        Thread thread2 = new Thread() {
            @Override
            public void run() {

                try {
                    thread1.join();//join方法會等待thread1運行完畢，才繼續(xù)執(zhí)行下面的代碼。
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                Thread.yield();//暫時讓出cpu,執(zhí)行其他任務(wù)
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                initString();
            }
        };
        thread2.start();
    }
}