package threadLearning.productCustomerModel;
/*
  wait/notify 機(jī)制：以資源為例，生產(chǎn)者生產(chǎn)一個資源，通知消費(fèi)者就消費(fèi)掉一個資源，生產(chǎn)者繼續(xù)生產(chǎn)資源，消費(fèi)者消費(fèi)資源，以此循環(huán)。
  wait()：使一個線程處于等待（阻塞）狀態(tài)，并且釋放所持有的對象的鎖；
  sleep()： 使一個正在運(yùn)行的線程處于睡眠狀態(tài)， 是一個靜態(tài)方法， 調(diào)用此方法要處理 InterruptedException 異常；
  notify()：喚醒一個處于等待狀態(tài)的線程，當(dāng)然在調(diào)用此方法的時(shí)候，并不能確切的喚醒某一個等待狀態(tài)的線程而是由 JVM 確定喚醒哪個線程，而且與優(yōu)先級無關(guān)；
  notityAll()：喚醒所有處于等待狀態(tài)的線程，該方法并不是將對象的鎖給所有線程，而是讓它們競爭，只有獲得鎖的線程才能進(jìn)入就緒狀態(tài)；
備注：java 5 通過 Lock 接口提供了顯示的鎖機(jī)制，Lock 接口中定義了加鎖（lock（）方法）和解鎖（unLock（）方法），增強(qiáng)了多線程編程的靈活性及對線程的協(xié)調(diào)
*/

//資源對象：包含商品名屬性；提供生產(chǎn)和消費(fèi)方法；
class Resource {
  private String name;//商品名
  private int count = 0;
  private boolean flag = false;//生產(chǎn)或者消費(fèi)的控制開關(guān)
  public synchronized void set(String name) {
    // 生產(chǎn)資源
    while (flag) {
      try {
        // 線程等待。消費(fèi)者消費(fèi)資源
        wait();
      } catch (Exception e) {
      }
    }
    this.name = name + "---" + count++;
    System.out.println(Thread.currentThread().getName() + "...生產(chǎn)者..."
        + this.name);
    flag = true;
    // 喚醒等待中的消費(fèi)者
    this.notifyAll();//喚醒在此對象監(jiān)視器上等待的所有線程  Object.notifyAll()
  }

  public synchronized void out() {
    // 消費(fèi)資源
    while (!flag) {
      // 線程等待，生產(chǎn)者生產(chǎn)資源
      try {
        wait();
      } catch (Exception e) {
      }
    }
    System.out.println(Thread.currentThread().getName() + "...消費(fèi)者..."
        + this.name);
    flag = false;
    // 喚醒生產(chǎn)者，生產(chǎn)資源
    this.notifyAll();
  }
}

// 生產(chǎn)者
class Producer implements Runnable {
  private Resource res;

  Producer(Resource res) {
    this.res = res;
  }

  // 生產(chǎn)者生產(chǎn)資源
  public void run() {
    while (true) {
      res.set("商品");
    }
  }
}

// 消費(fèi)者消費(fèi)資源
class Consumer implements Runnable {
  private Resource res;

  Consumer(Resource res) {
    this.res = res;
  }

  public void run() {
    while (true) {
      res.out();
    }
  }
}
public class ProducerConsumerDemo {
  public static void main(String[] args) {
    Resource r = new Resource();
    Producer pro = new Producer(r);
    Consumer con = new Consumer(r);
    Thread t1 = new Thread(pro);
    Thread t2 = new Thread(con);
    t1.start();
    t2.start();
  }
}

package threadLearning.thredLocal;
/*
1、該類提供了線程局部 (thread-local) 變量。這些變量不同于它們的普通對應(yīng)物，因?yàn)樵L問某個變量（通過其 get 或 set 方法）的每個線程都有自己的局部變量，它獨(dú)立于變量的初始化副本。ThreadLocal 實(shí)例通常是類中的 private static 字段，它們希望將狀態(tài)與某一個線程（例如：用戶 ID 或事務(wù) ID）相關(guān)聯(lián)。
2、ThreadLocal的使用
(1) 在關(guān)聯(lián)數(shù)據(jù)類中創(chuàng)建 private static ThreadLocal在下面的類中，私有靜態(tài) ThreadLocal 實(shí)例（serialNum）為調(diào)用該類的靜態(tài) SerialNum.get() 方法的每個線程維護(hù)了一個“序列號”，該方法將返回當(dāng)前線程的序列號。（線程的序列號是在第一次調(diào)用 SerialNum.get() 時(shí)分配的，并在后續(xù)調(diào)用中不會更改。 
每個線程都保持對其線程局部變量副本的隱式引用，只要線程是活動的并且 ThreadLocal 實(shí)例是可訪問的；在線程消失之后，其線程局部實(shí)例的所有副本都會被垃圾回收（除非存在對這些副本的其他引用）。 
*/ 
public class SerialNum {
  private static int nextSerialNum = 3;
  private static ThreadLocal serialNum = new ThreadLocal() {//創(chuàng)建一個線程本地變量
    protected synchronized Object initialValue() {
      return new Integer(nextSerialNum++);
    }
  };

  public static int get() {
    return ((Integer) (serialNum.get())).intValue();
  }
  
  public static void main(String args[]){
    Thread thead1=new Thread(new Runnable() {
      public void run() {
        System.out.println("thead1-->"+get());        
      }
    });
    Thread thead2=new Thread(new Runnable() {
      public void run() {
        System.out.println("thead2-->"+get());        
      }
    });
    thead1.start();
    thead2.start();
    /*
  同一個Thread啟動第二次會報(bào)錯java.lang.IllegalThreadStateExceptionThread報(bào)錯的原因，并不是說，重新啟動Thread導(dǎo)致的，
而是因?yàn)楣灿靡粋€Thread導(dǎo)致的，因?yàn)?，如果是?shí)現(xiàn)Runnable的類，每次啟動線程都需要new Thread(Runnable).start()，這就使得線
程沒有被共用。
    while(true){
      thead2.start();
      
    }
    */
  }
}

package threadLearning.thredLocal;
class Res {
  // 生成序列號共享變量
  public static Integer count = 0;
  public static ThreadLocal<Integer> threadLocal = new ThreadLocal<Integer>() {
    // 覆蓋返回此線程局部變量的當(dāng)前線程的“初始值”方法
    @Override
    protected Integer initialValue() {
      return 0;
    };
  };

  public Integer getNum() {
    int count = threadLocal.get() + 1;//get() 該方法返回當(dāng)前線程所對應(yīng)的線程局部變量
    threadLocal.set(count);//將此線程局部變量的當(dāng)前線程副本中的值設(shè)置為指定值
    return count;
  }
}

public class ThreadLocaDemo2 extends Thread {
  private Res res;

  public ThreadLocaDemo2(Res res) {
    this.res = res;
  }

  @Override
  public void run() {
    for (int i = 0; i < 3; i++) {
      System.out.println(Thread.currentThread().getName() + "---" + "i---" + i + "--num:" + res.getNum());
    }

  }

  public static void main(String[] args) {
    Res res = new Res();
    ThreadLocaDemo2 threadLocaDemo1 = new ThreadLocaDemo2(res);
    ThreadLocaDemo2 threadLocaDemo2 = new ThreadLocaDemo2(res);
    ThreadLocaDemo2 threadLocaDemo3 = new ThreadLocaDemo2(res);
    threadLocaDemo1.start();
    threadLocaDemo2.start();
    threadLocaDemo3.start();
  }
}

Thread-1---i---0--num:1
Thread-2---i---0--num:1
Thread-0---i---0--num:1
Thread-2---i---1--num:2
Thread-1---i---1--num:2
Thread-2---i---2--num:3
Thread-0---i---1--num:2
Thread-1---i---2--num:3
Thread-0---i---2--num:3