java167-生产者消费者问题
作者：互联网
class Ck {
private char[] r1 = new char[8];
private int wp = 0;
public synchronized void shengchan(char aa) {
while (wp == r1.length) //满了
try {
this.wait();
} catch (Exception e) {
}
this.notify();//叫醒另一个线程，当前线程处于就绪状态
r1[wp] = aa;
++wp;
System.out.println( "生产者正在生产第" + wp + "个产品，该产品为" + aa );
}
public synchronized void xiaofei() {
char aa;
while (wp == 0)
try {
this.wait();
} catch (Exception e) {
}
this.notify();
aa = r1[wp - 1];
System.out.println( "生产者正在消费第" + wp + "个产品，该产品为" + aa );
--wp;
}//代码生产消费问题实现
}
定义生产
//生产
public class Sc implements Runnable {
private Ck xc = null;
public Sc(Ck xc) {
this.xc = xc;
}
public void run() {
char aa;
for (int i = 0; i < 26; i++) {
aa = (char) ('A' + i);
xc.shengchan( aa );
}
}
}
定义消费
//消费
public class Xf implements Runnable {
private Ck xc = null;
public Xf(Ck xc) {
this.xc = xc;
}
public void run() {
char aa;
for (int i = 0; i < 26; i++) {
aa = (char) ('A' + i);
xc.xiaofei();
}
}
}
测试类
//代码生产消费问题实现
public class test119{
public static void main(String[] args){
Ck ck=new Ck();
Sc sc=new Sc( ck );
Xf xf=new Xf(ck);
Thread xc1=new Thread( sc );
xc1.start();
Thread xc2=new Thread( xf );
xc2.start();
}
}
运行结果
标签：aa,Ck,消费者,生产者,xc,char,wp,public,java167 来源： https://www.cnblogs.com/yao-655442/p/16448225.html