package com.xhj.thread;
  /**
   * 線程同步的運(yùn)用
   * 
   * @author XIEHEJUN
   * 
   */
  public class SynchronizedThread {
    class Bank {
      private int account = 100;
      public int getAccount() {
        return account;
      }
      /**
       * 用同步方法實(shí)現(xiàn)
       * 
       * @param money
       */
      public synchronized void save(int money) {
        account += money;
      }
      /**
       * 用同步代碼塊實(shí)現(xiàn)
       * 
       * @param money
       */
      public void save1(int money) {
        synchronized (this) {
          account += money;
        }
      }
    }
    class NewThread implements Runnable {
      private Bank bank;
      public NewThread(Bank bank) {
        this.bank = bank;
      }
      @Override
      public void run() {
        for (int i = 0; i < 10; i++) {
          // bank.save1(10);
          bank.save(10);
          System.out.println(i + "賬戶余額為：" + bank.getAccount());
        }
      }
    }
    /**
     * 建立線程，調(diào)用內(nèi)部類
     */
    public void useThread() {
      Bank bank = new Bank();
      NewThread new_thread = new NewThread(bank);
      System.out.println("線程1");
      Thread thread1 = new Thread(new_thread);
      thread1.start();
      System.out.println("線程2");
      Thread thread2 = new Thread(new_thread);
      thread2.start();
    }
    public static void main(String[] args) {
      SynchronizedThread st = new SynchronizedThread();
      st.useThread();
    }
  }

//只給出要修改的代碼，其余代碼與上同
    class Bank {
      //需要同步的變量加上volatile
      private volatile int account = 100;

      public int getAccount() {
        return account;
      }
      //這里不再需要synchronized 
      public void save(int money) {
        account += money;
      }
    ｝

//只給出要修改的代碼，其余代碼與上同
    class Bank {
      
      private int account = 100;
      //需要聲明這個(gè)鎖
      private Lock lock = new ReentrantLock();
      public int getAccount() {
        return account;
      }
      //這里不再需要synchronized 
      public void save(int money) {
        lock.lock();
        try{
          account += money;
        }finally{
          lock.unlock();
        }
        
      }
    ｝

//只改Bank類，其余代碼與上同
    public class Bank{
      //使用ThreadLocal類管理共享變量account
      private static ThreadLocal<Integer> account = new ThreadLocal<Integer>(){
        @Override
        protected Integer initialValue(){
          return 100;
        }
      };
      public void save(int money){
        account.set(account.get()+money);
      }
      public int getAccount(){
        return account.get();
      }
    }

package com.xhj.thread;
import java.util.Random;
import java.util.concurrent.LinkedBlockingQueue;
/**
 * 用阻塞隊(duì)列實(shí)現(xiàn)線程同步 LinkedBlockingQueue的使用
 * 
 * @author XIEHEJUN
 * 
 */
public class BlockingSynchronizedThread {
  /**
   * 定義一個(gè)阻塞隊(duì)列用來(lái)存儲(chǔ)生產(chǎn)出來(lái)的商品
   */
  private LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<Integer>();
  /**
   * 定義生產(chǎn)商品個(gè)數(shù)
   */
  private static final int size = 10;
  /**
   * 定義啟動(dòng)線程的標(biāo)志，為0時(shí)，啟動(dòng)生產(chǎn)商品的線程；為1時(shí)，啟動(dòng)消費(fèi)商品的線程
   */
  private int flag = 0;
  private class LinkBlockThread implements Runnable {
    @Override
    public void run() {
      int new_flag = flag++;
      System.out.println("啟動(dòng)線程 " + new_flag);
      if (new_flag == 0) {
        for (int i = 0; i < size; i++) {
          int b = new Random().nextInt(255);
          System.out.println("生產(chǎn)商品：" + b + "號(hào)");
          try {
            queue.put(b);
          } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
          }
          System.out.println("倉(cāng)庫(kù)中還有商品：" + queue.size() + "個(gè)");
          try {
            Thread.sleep(100);
          } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
          }
        }
      } else {
        for (int i = 0; i < size / 2; i++) {
          try {
            int n = queue.take();
            System.out.println("消費(fèi)者買去了" + n + "號(hào)商品");
          } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
          }
          System.out.println("倉(cāng)庫(kù)中還有商品：" + queue.size() + "個(gè)");
          try {
            Thread.sleep(100);
          } catch (Exception e) {
            // TODO: handle exception
          }
        }
      }
    }
  }
  public static void main(String[] args) {
    BlockingSynchronizedThread bst = new BlockingSynchronizedThread();
    LinkBlockThread lbt = bst.new LinkBlockThread();
    Thread thread1 = new Thread(lbt);
    Thread thread2 = new Thread(lbt);
    thread1.start();
    thread2.start();
  }
}

class Bank {
    private AtomicInteger account = new AtomicInteger(100);
    public AtomicInteger getAccount() {
      return account;
    }
    public void save(int money) {
      account.addAndGet(money);
    }
  }