现在的位置: 首页 > 综合 > 正文

多线程访问共享对象和数据的方式

2018年06月05日 ⁄ 综合 ⁄ 共 1586字 ⁄ 字号 评论关闭

如果每个线程执行的代码相同,可以使用同一个Runnable对象,这个Runnable对象中有那个共享数据,比如:在之前提到的卖票程序中,是两个线程,同时减去100张票,也就是说这两个线程的操作都是一样的,所以我们可以使用同一个Runnable对象。

如果每个线程执行的代码不同,这时候需要不同的Runnable对象,有如下两种方式来实现这些Runnable对象之间的数据共享:
1:将共享的数据封装在另外一个对象中,然后将这个对象逐一传递给各个Runnable对象,每个线程对共享数据的操作方法也分配到那个对象身上去。

2:将这些Runnable对象作为某一个类中的内部类,共享数据作为这个外部类中的成员变量,每个线程对共享数据的操作方法也分配给外部类。

案例:设计四个线程,其中两个线程每次对变量j增加1,另外两个线程每次减少1。

/**
 * 数据类
 */
class MyData {

	private int j = 0;

	/* 变量j的自增 */
	public synchronized void increment() {
		j++;
		System.out.println(Thread.currentThread().getName() +"自增: "+ j);
	}

	/* 变量j的自减 */
	public synchronized void decrement() {
		j--;
		System.out.println(Thread.currentThread().getName() +"自减: "+ j);
	}
}

/**
 * 使变量自增的线程类
 */
class MyRunnable1 implements Runnable {

	/* 定义数据类 */
	private MyData data;

	/* 通过构造函数把对象传过来 */
	public MyRunnable1(MyData data) {
		this.data = data;
	}

	public void run() {
		/* 调用数据类中的方法,使变量自增 */
		data.increment();
	}

}

/**
 * 使变量自减的线程类
 */
class MyRunnable2 implements Runnable {

	/* 定义数据类 */
	private MyData data;

	/* 通过构造函数把对象传过来 */
	public MyRunnable2(MyData data) {
		this.data = data;
	}

	public void run() {
		/* 调用数据类中的方法,使变量自增 */
		data.decrement();
	}

}

/**
 * 测试类
 */
public class MultiThreadShareData {

	public static void main(String[] args) {

		/******************** 实现Runnable对象之间数据共享的第一种方式 ***************************/
		/* 创建数据类 */
		MyData data = new MyData();
		
		/*循环创建四个线程*/
		for (int i=0; i<2; i++){
			/* 创建线程使变量自增 */
			new Thread(new MyRunnable1(data)).start();
			/* 创建线程使变量自减 */
			new Thread(new MyRunnable2(data)).start();
		}
		

		/******************** 实现Runnable对象之间数据共享的第二种方式 **************************
		final MyData data2 = new MyData();
		
		new Thread(new Runnable() {

			@Override
			public void run() {
				data2.decrement();
			}
		}).start();
		
		new Thread(new Runnable() {
			
			@Override
			public void run() {
				data2.increment();
			}
		}).start();*/

	}

}

抱歉!评论已关闭.