写出一组模拟生产者/消费者的协作程序
其中包括一个WoToujava代表消息
一个MsgQueuejava为一个队列提供put(Message msg)方法和get()方法
一个Produerjava为生产者线程在其run方法中每隔秒产生一个Message对像并放入MsgQueue队列
一个Consumerjava为消费者线程在其run方法中不断从MsgQueue队列中获取Message对像并显示在屏幕上
一个TestMainjava在其main方法中启动个Produer线程和个消费者线程
要求
对于MsgQueuejava队列的长度为当消息超过个时put()方法需要阻塞当消息队列为空时
get()方法需要阻塞
public class ProducerConsumer {
public static void main(String[] args) {
SyncStack ss = new SyncStack();
Producer p= new Producer(ssp);
Consumer c= new Consumer(ssc);
Producer p= new Producer(ssp);
Consumer c= new Consumer(ssc);
}
}
class WoTou<T> {
int id;
WoTou(int id) {
thisid = id;
}
public String toString() {
return WoTou : + id;
}
}
class SyncStack {
int index = ;
WoTou[] arrWT = new WoTou[];
public void push(WoTou wt) {
while(index == arrWTlength) {
try {
thiswait();
} catch (InterruptedException e) {
eprintStackTrace();
}
}
thisnotifyAll();
arrWT[index] = wt;
index ++;
}
public WoTou pop() {
while(index == ) {
try {
thiswait();
} catch (InterruptedException e) {
eprintStackTrace();
}
}
thisnotifyAll();
index;
return arrWT[index];
}
}
class Producer implements Runnable {
SyncStack ss = null;
String a;
Producer(SyncStack ssString a) {
thisss = ss;
thisa= a;
Thread t=new Thread(thisa);
tstart();
}
public void run() {
for(int i=; i<; i++) {
synchronized(ss){
WoTou wt = new WoTou(i);
sspush(wt);
Systemoutprintln(a+ 生产了 + wt);}
try {
Threadsleep((int)(Mathrandom() * ));
} catch (InterruptedException e) {
eprintStackTrace();
}
}
}
}
class Consumer implements Runnable {
SyncStack ss = null;
String a;
Thread t;
Consumer(SyncStack ssString a) {
thisss = ss;
thisa= a;
t=new Thread(thisa);
tstart();
}
public void run() {
for(int i=; i<; i++) {
synchronized(ss){
WoTou wt = sspop();
Systemoutprintln(a+ 消费了: + wt);}
try {
Threadsleep((int)(Mathrandom() * ));
} catch (InterruptedException e) {
eprintStackTrace();
}
}
}
}
p 生产了WoTou :
p 生产了WoTou :
p 生产了WoTou :
c 消费了: WoTou :
c 消费了: WoTou :
p 生产了WoTou :
c 消费了: WoTou :
c 消费了: WoTou :
p 生产了WoTou :
p 生产了WoTou :
c 消费了: WoTou :
p 生产了WoTou :
p 生产了WoTou :
c 消费了: WoTou :
p 生产了WoTou :
p 生产了WoTou :
c 消费了: WoTou :
p 生产了WoTou :
p 生产了WoTou :
c 消费了: WoTou :
c 消费了: WoTou :
p 生产了WoTou :
c 消费了: WoTou :
p 生产了WoTou :
p 生产了WoTou :
p 生产了WoTou :
栈里有个
作为多线程交互一的一个重要应用定义用户输入和输出的列队类或者堆栈类一定要看成一个整体放进同步语句块里面不能简单的分别调用输入同步方法或者输出同步方法下面的程序就有问题 下面这个是一个教程例子但是结果不对究其原因实际上是因为列队类或者堆栈类是一个可变类 这种可变类要是有参数传递给某些不可变类时可变类的构造方法必须也设置成为同步方法不然就会出错
public class ProducerConsumer {
public static void main(String[] args) {
SyncStack ss = new SyncStack();
Producer p = new Producer(ss);
Consumer c = new Consumer(ss);
new Thread(p)start();
new Thread(p)start();
new Thread(p)start();
new Thread(c)start();
}
}
class WoTou {
int id;
WoTou(int id) {
thisid = id;
}
public String toString() {
return WoTou : + id;
}
}
class SyncStack {
int index = ;
WoTou[] arrWT = new WoTou[];
public synchronized void push(WoTou wt) {
while(index == arrWTlength) {
try {
thiswait();
} catch (InterruptedException e) {
eprintStackTrace();
}
}
thisnotifyAll();
arrWT[index] = wt;
index ++;
}
public synchronized WoTou pop() {
while(index == ) {
try {
thiswait();
} catch (InterruptedException e) {
eprintStackTrace();
}
}
thisnotifyAll();
index;
return arrWT[index];
}
}
class Producer implements Runnable {
SyncStack ss = null;
Producer(SyncStack ss) {
thisss = ss;
}
public void run() {
for(int i=; i<; i++) {
WoTou wt = new WoTou(i);
sspush(wt);
Systemoutprintln(生产了 + wt);
try {
Threadsleep((int)(Mathrandom() * ));
} catch (InterruptedException e) {
eprintStackTrace();
}
}
}
}
class Consumer implements Runnable {
SyncStack ss = null;
Consumer(SyncStack ss) {
thisss = ss;
}
public void run() {
for(int i=; i<; i++) {
WoTou wt = sspop();
Systemoutprintln(消费了: + wt);
try {
Threadsleep((int)(Mathrandom() * ));
} catch (InterruptedException e) {
eprintStackTrace();
}
}
}
}
运行后的结果栈里有个 为什么会这样呢?你思考一下
