Java多线程学习:多个线程间共享数据

多个线程访问共享对象和数据的方式有两种状况:
一、每一个线程执行的代码相同,例如,卖票:多个窗口同时卖这100张票,这100张票须要多个线程共享。
二、每一个线程执行的代码不一样,例如:设计四个线程,其中两个线程每次对j增长1,另外两个线程每次对j减小1。java

a、若是每一个线程执行的代码相同,能够使用同一个Runnable对象,这个对象中有共享数据(静态变量)。卖票就能够这样作,每一个窗口都在作卖票任务,卖的票都是同一个数据(点击查看具体案例)。多线程

b、若是每一个线程执行的代码不一样,就须要使用不一样的Runnable对象,有两种方式实现Runnable对象之间的数据共享:
1)、将共享数据单独封装到一个对象中,同时在对象中提供操做这些共享数据的方法,能够方便实现对共享数据各项操做的互斥和通讯。
二、)将各个Runnable对象做为某个类的内部类,共享数据做为外部类的成员变量,对共享数据的操做方法也在外部类中提供,以便实现互斥和通讯,内部类的Runnable对象调用外部类中操做共享数据的方法便可。ide

package com.ljq.test.thread;
  
/**
 * 多个线程之间共享数据的方式
 *
 * 设计四个线程,其中两个线程每次对j增长1,另外两个线程每次对j减小1。循环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();
  
  }
  
}
  
/**
 * 建立线程类,负责对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();
    }
      
  }
}
  
/**
 * 建立线程类,负责对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();
    }
      
  }
}
  
/**
 * 封装共享数据
 *
 * @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);
  }
    
    
}

注意:要同步互斥的几段代码最好分别放在几个独立的方法中,这些方法再放在同一个类中,这样比较容易实现它们之间的同步互斥和通讯。this

 

推荐阅读:url

  多线程间的数据共享和对象独立,ThreadLocal详解.net

  Java多线程共享数据、同步、通讯线程

  Java多线程锁如何进行数据同步共享设计

相关文章
相关标签/搜索