欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java多线程编程之访问共享对象和数据的方法

程序员文章站 2024-03-04 16:15:35
多个线程访问共享对象和数据的方式有两种情况: 1、每个线程执行的代码相同,例如,卖票:多个窗口同时卖这100张票,这100张票需要多个线程共享。 2、每个线程执行的代码...

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

a、如果每个线程执行的代码相同,可以使用同一个runnable对象,这个对象中有共享数据。卖票就可以这样做,每个窗口都在做卖票任务,卖的票都是同一个数据(点击查看具体案例)。

b、如果每个线程执行的代码不同,就需要使用不同的runnable对象,有两种方式实现runnable对象之间的数据共享:
1)、将共享数据单独封装到一个对象中,同时在对象中提供操作这些共享数据的方法,可以方便实现对共享数据各项操作的互斥和通信。
2、)将各个runnable对象作为某个类的内部类,共享数据作为外部类的成员变量,对共享数据的操作方法也在外部类中提供,以便实现互斥和通信,内部类的runnable对象调用外部类中操作共享数据的方法即可。

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);
  }
   
   
}

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