多线程应用问题 - 黑马程序员技术交流社区

public class Threadtest {
public static void main(String[] args) {
Factory fac = new Factory();
Producer p = new Producer(fac);
Consumer c = new Consumer(fac);
Thread tp = new Thread(p);
Thread tc = new Thread(c);
tp.start();
tc.start();
}
}
class Goods {
private int id;
public int length;
Goods(int id) {
this.id = id;
}
public String toString() {
return "Goods :" + id;
}
}
class Factory {
Goods goods[] = new Goods[10];
int index = 0;
public synchronized void push(Goods gs) {
try {
while (index == goods.length) {
System.out.println("仓库满了,停止生产。。。。");
this.wait();
}
this.notify();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (IllegalMonitorStateException e) {
e.printStackTrace();
}
goods[index] = gs;
index++;
System.out.println("生产了：" + gs + " 共有" + index + "个产品");
}
public synchronized Goods pop() {
try {
while (index == 0) {
System.out.println("仓库东西已经消费光了。。。。");
this.wait();
}
this.notify();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (IllegalMonitorStateException e) {
e.printStackTrace();
}
index--;
System.out.println("消费了：---------" + goods[index] + " 共有" + index
+ "个产品");
return goods[index];
}
}
class Producer implements Runnable {
Factory fac = new Factory();
Producer(Factory fac) {
this.fac = fac;
}
public void run() {
for (int i = 0; i < 10; i++) {
Goods gs = new Goods(i);
fac.push(gs);
try {
Thread.sleep((int) (Math.random() * 500));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Consumer implements Runnable {
Factory fac = new Factory();
Consumer(Factory fac) {
this.fac = fac;
}
public void run() {
for (int i = 0; i < 10; i++) {
fac.pop();
try {
Thread.sleep((int) (Math.random() * 1000));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}

复制代码