两种多线程操作共享数据的方法

/*

方法一：

将共享数据作为外部类的成员变量，然后在外部类方法中创建两个含有内部Runable类的对象线程，在这个内部Runnable对象中执行共享数据

方法二：

两个对象实现runnable接口，把数据封装到对象2中，然后将操作数据作为两个对象的参数构造这两个对象，构造的两个对象分别作为构造两个线程的参数

*/

package zhu.test;

/**

* 需求：

* 使同一份数据分别进行 加1 减1 交替出现 10次

* @author nn

*

*/

public class ThreadShareDataDemo1 {

public static void main(String[] args) {

final ShareDATA DataObj= new ShareDATA();//静态方法内不允许非静态内部类

//线程 1 增加

new Thread(

new Runnable() {

@Override

public void run()

{

for(int i=0;i<10;i++)

DataObj.add();

}

}

).start();

//线程2 减少

new Thread(

new Runnable() {

@Override

public void run() {

for(int i=0;i<10;i++)

DataObj.incre();

}

}

).start();

}

}

class ShareDATA{

boolean isAddTrue=true;

int data;

synchronized void incre()

{

if(isAddTrue)

{

try {

this.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

this.data--;

System.out.println("inre"+this.data);

this.isAddTrue=true;

this.notify();

}

synchronized void add()

{

if(!this.isAddTrue)

{

try {

this.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

this.data++;

System.out.println("add"+this.data);

this.isAddTrue=false;

this.notify();

}

}

package zhu.test;

/**

* 需求：

* 使同一份数据分别进行 加1 减1 交替出现 10次

* @author nn

*

*/

public class CopyOfThreadShareDataDemo2 {

static int data=0;

public static void main(String[] args) {

Data data= new Data(0);

//线程 1 增加

new Thread(

new RunWraper1(data)//要传入对象

).start();

//线程2 减少

new Thread(

new RunWraper2(data)

).start();

}

}

class Data{

int data;

boolean isJiaTrue=true;

public Data(int da){this.data = da;}

}

class RunWraper1 implements Runnable

{

Data data;

public RunWraper1(Data da){this.data = da;}

@Override

public void run() {

for(int i=0;i<10;i++)

{

synchronized(data){

if(data.isJiaTrue)

{

try {

data.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

data.data--;

System.out.println("jian"+data.data);

data.isJiaTrue = true;

data.notify();

}

}

}

}

class RunWraper2 implements Runnable

{

Data data;

public RunWraper2(Data da){this.data = da;}

@Override

public synchronized void run() {

for(int i=0;i<10;i++)

{

synchronized(data){

if(!data.isJiaTrue)

{

try {

data.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

data.data++;

System.out.println("jia"+data.data);

data.isJiaTrue = false;

data.notify();

}

}

}

}