package com.xhj.thread;
  /**
   * 线程同步的运用
   * 
   * @author XIEHEJUN
   * 
   */
  public class SynchronizedThread {
    class Bank {
      private int account = 100;
      public int getAccount() {
        return account;
      }
      /**
       * 用同步方法实现
       * 
       * @param money
       */
      public synchronized void save(int money) {
        account += money;
      }
      /**
       * 用同步代码块实现
       * 
       * @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());
        }
      }
    }
    /**
     * 建立线程，调用内部类
     */
    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;
      //需要声明这个锁
      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;
/**
 * 用阻塞队列实现线程同步 LinkedBlockingQueue的使用
 * 
 * @author XIEHEJUN
 * 
 */
public class BlockingSynchronizedThread {
  /**
   * 定义一个阻塞队列用来存储生产出来的商品
   */
  private LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<Integer>();
  /**
   * 定义生产商品个数
   */
  private static final int size = 10;
  /**
   * 定义启动线程的标志，为0时，启动生产商品的线程；为1时，启动消费商品的线程
   */
  private int flag = 0;
  private class LinkBlockThread implements Runnable {
    @Override
    public void run() {
      int new_flag = flag++;
      System.out.println("启动线程 " + new_flag);
      if (new_flag == 0) {
        for (int i = 0; i < size; i++) {
          int b = new Random().nextInt(255);
          System.out.println("生产商品：" + b + "号");
          try {
            queue.put(b);
          } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
          }
          System.out.println("仓库中还有商品：" + queue.size() + "个");
          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("消费者买去了" + n + "号商品");
          } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
          }
          System.out.println("仓库中还有商品：" + queue.size() + "个");
          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);
    }
  }