如果每个线程执行的代码相同,可以使用同一个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();*/ } }