Java多線程編程之訪問共享對象和數(shù)據(jù)的方法

更新時間：2015年05月19日 10:41:45 投稿：junjie

這篇文章主要介紹了Java多線程編程之訪問共享對象和數(shù)據(jù)的方法,多個線程訪問共享對象和數(shù)據(jù)的方式有兩種情況,本文分別給出代碼實例,需要的朋友可以參考下

多個線程訪問共享對象和數(shù)據(jù)的方式有兩種情況：
1、每個線程執(zhí)行的代碼相同，例如，賣票：多個窗口同時賣這100張票，這100張票需要多個線程共享。
2、每個線程執(zhí)行的代碼不同，例如：設(shè)計四個線程，其中兩個線程每次對j增加1，另外兩個線程每次對j減少1。

a、如果每個線程執(zhí)行的代碼相同，可以使用同一個Runnable對象，這個對象中有共享數(shù)據(jù)。賣票就可以這樣做，每個窗口都在做賣票任務(wù)，賣的票都是同一個數(shù)據(jù)(點擊查看具體案例)。

b、如果每個線程執(zhí)行的代碼不同，就需要使用不同的Runnable對象，有兩種方式實現(xiàn)Runnable對象之間的數(shù)據(jù)共享：
1）、將共享數(shù)據(jù)單獨封裝到一個對象中，同時在對象中提供操作這些共享數(shù)據(jù)的方法，可以方便實現(xiàn)對共享數(shù)據(jù)各項操作的互斥和通信。
2、）將各個Runnable對象作為某個類的內(nèi)部類，共享數(shù)據(jù)作為外部類的成員變量，對共享數(shù)據(jù)的操作方法也在外部類中提供，以便實現(xiàn)互斥和通信，內(nèi)部類的Runnable對象調(diào)用外部類中操作共享數(shù)據(jù)的方法即可。

package com.ljq.test.thread;
 
/**
 * 多個線程之間共享數(shù)據(jù)的方式
 *
 * 設(shè)計四個線程，其中兩個線程每次對j增加1，另外兩個線程每次對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)建線程類，負責(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)建線程類，負責(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);
  }
   
   
}

注意：要同步互斥的幾段代碼最好分別放在幾個獨立的方法中，這些方法再放在同一個類中，這樣比較容易實現(xiàn)它們之間的同步互斥和通信。

您可能感興趣的文章: