Question

创建一个java程序:两个或两个以上的线程需要访问共享资源

Answer 1

试一试生产消费者问题吧.一个栈空间装WOTOU然后开启两个线程同时消费和生产..满20次就停止public class Test{
public static void main(String[] args){
SyncStack ss = new SyncStack();
Producer p = new Producer(ss);
Consumer c = new Consumer(ss);
Thread t = new Thread(p);
Thread tt = new Thread(c);
t.start();
tt.start();
}
}class WoTou{
int id;
WoTou(int id){
this.id = id;
}
public String toString(){
return "WoTou" + id;
}
}class SyncStack{ int index = 0;
WoTou[] arrWT = new WoTou[6];
public synchronized void push(WoTou wt){
if(index == arrWT.length){
try{
this.wait();
}catch(InterruptedException e){
e.printStackTrace();
}

}
this.notify();
arrWT[index] = wt;
index ++;

}
public synchronized WoTou pop(){
if(index == 0){
try{
this.wait();
}catch(InterruptedException e){
e.printStackTrace();
}
}
this.notify();
index --;
return arrWT[index];

}
}class Producer implements Runnable{
SyncStack ss = null;
Producer(SyncStack ss){
this.ss = ss;
}
public void run(){
for(int i = 1;i<20;i++){
WoTou wt = new WoTou(i);
ss.push(wt);
System.out.println("生产了:" + wt);
try{
Thread.sleep(1000);
}catch(InterruptedException e){
e.printStackTrace();
}
}
}
}
class Consumer implements Runnable{
SyncStack ss = null;
Consumer(SyncStack ss){
this.ss = ss;
}
public void run(){
for(int i = 1;i<20;i++){
WoTou wt = ss.pop();

System.out.println("消费了:" + wt);
try{
Thread.sleep(1000);
}catch(InterruptedException e){
e.printStackTrace();
}
}
}
}