package com.ljq.test.thread;
 
/**
 * 多個(gè)線程之間共享數(shù)據(jù)的方式
 *
 * 設(shè)計(jì)四個(gè)線程，其中兩個(gè)線程每次對j增加1，另外兩個(gè)線程每次對j減少1。循環(huán)100次。
 *
 * @author Administrator
 *
 */
public class MultiThreadShareData {
  private static ShareData data1 = new ShareData();
 
  public static void main(String[] args) {
    ShareData data2 = new ShareData();
    new Thread(new DecrementRunnable(data2)).start();
    new Thread(new IncrementRunnable(data2)).start();
 
    final ShareData data1 = new ShareData();
    new Thread(new Runnable() {
      @Override
      public void run() {
        data1.decrement();
 
      }
    }).start();
    new Thread(new Runnable() {
      @Override
      public void run() {
        data1.increment();
 
      }
    }).start();
 
  }
 
}
 
/**
 * 創(chuàng)建線程類，負(fù)責(zé)對j減少1
 *
 * @author Administrator
 *
 */
class DecrementRunnable implements Runnable {
  private ShareData data;
 
  public DecrementRunnable(ShareData data) {
    this.data = data;
  }
 
  public void run() {
    for(int i=0; i<100; i++){
      data.decrement();
    }
     
  }
}
 
/**
 * 創(chuàng)建線程類，負(fù)責(zé)對j增加1
 *
 * @author Administrator
 *
 */
class IncrementRunnable implements Runnable {
  private ShareData data;
 
  public IncrementRunnable(ShareData data) {
    this.data = data;
  }
 
  public void run() {
    for(int i=0; i<100; i++){
      data.increment();
    }
     
  }
}
 
/**
 * 封裝共享數(shù)據(jù)
 *
 * @author Administrator
 *
 */
class ShareData {
  private int j = 0;
 
  /**
   * 每次對j增加1
   */
  public synchronized void increment() {
    j++;
    System.out.println("j++="+j);
  }
 
  /**
   * 每次對j減少1
   */
  public synchronized void decrement() {
    j--;
    System.out.println("j--="+j);
  }
   
   
}