java5编程(6)多个线程之间共享数据的方式探讨 (一)

2014-11-24 07:45:55 · 作者: · 浏览: 1

如果每个线程执行的代码相同,可以使用同一个Runnable对象,这个Runnable对象中有那个共享的数据,例如 买票系统就是那么做的。

[java]
package com.itm.thread;

public class MultiThreadShareData {


public static void main(String[] args) {

ShareData1 data1 = new ShareData1();

//(1)种方法。
new Thread(data1).start();

new Thread(data1).start();
}

}

class ShareData1 implements Runnable{

private int count = 100;
@Override
public void run() {
while(true){
count--;
}
}


private int j = 0;
public synchronized void increment(){
j++;
}

public synchronized void descrement(){
j--;
}
}
package com.itm.thread;

public class MultiThreadShareData {


public static void main(String[] args) {

ShareData1 data1 = new ShareData1();

//(1)种方法。
new Thread(data1).start();

new Thread(data1).start();
}

}

class ShareData1 implements Runnable{

private int count = 100;
@Override
public void run() {
while(true){
count--;
}
}


private int j = 0;
public synchronized void increment(){
j++;
}

public synchronized void descrement(){
j--;
}
}

\


如果 每个线程执行的代码不同 怎么解决呢???

[java]
package com.itm.thread;

public class MultiThreadShareData2 {

private final static TwoShareData data1 = new TwoShareData();

public static void main(String[] args) {

// 此为 共享数据。
TwoShareData data2 = new TwoShareData();

new Thread(new OneMyRunnable(data2)).start();
new Thread(new TwoMyRunnable(data2)).start();

// 局部变量 加上 final。也可以行得通。
final TwoShareData data1 = new TwoShareData();
// Runnable 为 内部类。
new Thread(new Runnable(){

@Override
public void run() {
data1.descrement();
}

}).start();

new Thread(new Runnable(){

@Override
public void run() {
data1.increment();
}

}).start();

}

}
class OneMyRunnable implements Runnable{
private TwoShareData data1;
public OneMyRunnable(TwoShareData data1){
this.data1 = data1;
}
public void run(){
data1.descrement();
}
}

class TwoMyRunnable implements Runnable{
private TwoShareData data1;
public TwoMyRunnable(TwoShareData data1){
this.data1 = data1;
}
public void run(){
data1.increment();
}
}

class TwoShareData {

private int j = 0;
public synchronized void increment(){
j++;
}

public synchronized void descrement(){
j--;
}
}
package com.itm.thread;

public class MultiThreadShareData2 {

private final static TwoShareData data1 = new TwoShareData();

public static void main(String[] args) {

// 此为 共享数据。
TwoShareData data2 = new TwoShareData();

new Thread(new OneMyRunnable(data2)).start();
new Thread(new TwoMyRunnable(data2)).start();