在 Java 传统线程机制中的共享数据方式,大致可以简单分两种情况:
- 多个线程行为一致,共同操作一个数据源。也就是每个线程执行的代码相同,可以使用同一个 Runnable 对象,这个 Runnable 对象中有那个共享数据,例如,卖票系统就可以这么做。
- 多个线程行为不一致,共同操作一个数据源。也就是每个线程执行的代码不同,这时候需要用不同的Runnable 对象。例如,银行存取款。
1、同样的代码启动多个线程
启动多个线程,执行同一段代码,一个例子就是卖票系统,参考前面的【线程安全与同步】
这种情况下的共享数据可以以成员变量的形式直接定义在线程类中。
2、不同的代码启动多个线程
比如,设计两个线程,其中一个线程每次对j增加1;另一个线程每次对j减少1。
方式一
将要操作的变量和对变量操作的方法单独定义到一个普通类中,然后定义两个线程类,线程类中调用定义的方法。再在线程类对象中传递普通类对象,并开启线程。
public class Share {
public static void main(String[] args) {
DataShare dataShare = new DataShare();
dataShare.setJ(100);
ShareDate1 date1 = new ShareDate1(dataShare);
ShareDate2 date2 = new ShareDate2(dataShare);
//开启线程
new Thread(date1).start();
new Thread(date2).start();
}
//增加的线程
static class ShareDate1 implements Runnable{
private DataShare dataShare;
public ShareDate1(DataShare dataShare) {
this.dataShare = dataShare;
}
@Override
public void run() {
dataShare.increment();
System.out.println(dataShare.getJ());
}
}
//减少的线程
static class ShareDate2 implements Runnable{
private DataShare dataShare;
public ShareDate2(DataShare dataShare) {
this.dataShare = dataShare;
}
@Override
public void run() {
dataShare.decrement();
System.out.println(dataShare.getJ());
}
}
//对共享数据进行操作的类
//将执行任务的方法放在同一个类中,实现线程互斥
static class DataShare{
private int j;
public synchronized void increment(){
j++;
}
public synchronized void decrement(){
j--;
}
public int getJ() {
return j;
}
public void setJ(int j) {
this.j = j;
}
}
}
方式2
将这些 Runnable 对象作为某一个类中的内部类,共享数据作为这个外部类中的成员变量,每个线程对共享数据的操作方法也分配给外部类,以便实现对共享数据进行的各个操作的互斥和通信,作为内部类的各个Runnable 对象调用外部类的这些方法。