激情久久久久久久,国产亚洲第一区,国产麻豆日韩

Goods.java

package com.bebig.producerconsumer;

//商品

public class Goods {

private int id;

public Goods(int id) {

this.setId(id);

}

public void setId(int id) {

this.id = id;

}

public int getId() {

return id;

}

Cart.java

package com.bebig.producerconsumer;

//購(gòu)物車

public class Cart {

private final int MAXVALUE = 6;// 購(gòu)物車?yán)镒疃嗄艽娣诺纳唐窋?shù)量

private int index = 0;

private Goods[] goods = new Goods[MAXVALUE];

public synchronized void push(String name, Goods g) {

while (index == goods.length) {

// 購(gòu)物車?yán)餄M了就不要放物品進(jìn)來(lái)了

try {

System.out.println("----購(gòu)物車?yán)锏纳唐芬褲M,停止生產(chǎn).");

this.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

this.notifyAll();

this.goods[index] = g;

index++;

System.out.println("生產(chǎn)者" + name + "向購(gòu)物車?yán)锓胖昧艘患唐?");

}

public synchronized Goods pop(String name) {

while (0 == index) {

// 購(gòu)物車?yán)锟樟司筒灰∥锲烦鋈チ?/span>

try {

System.out.println("----購(gòu)物車?yán)锏纳唐芬芽?停止消費(fèi).");

this.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

this.notifyAll();

index--;

System.out.println("消費(fèi)者" + name + "從購(gòu)物車取走了一件商品.");

return this.goods[index];

}

Producer.java

package com.bebig.producerconsumer;

//生產(chǎn)者

public class Producer implements Runnable {

private Cart cart = null;

private String name;

public Producer(Cart c, String name) {

this.cart = c;

this.setName(name);

}

@Override

public void run() {

for (int i = 1; i < 10; i++) {

cart.push(this.getName(), new Goods(i));

try {

Thread.sleep((int) (Math.random() * 1000));

} catch (InterruptedException e) {

e.printStackTrace();

}

public void setName(String name) {

this.name = name;

}

public String getName() {

return name;

}

Consumer.java

package com.bebig.producerconsumer;

//消費(fèi)者

public class Consumer implements Runnable {

private Cart cart = null;

private String name;

public Consumer(Cart c, String name) {

this.name = name;

this.cart = c;

}

@Override

public void run() {

for (int i = 1; i < 10; i++) {

cart.pop(this.getName());

try {

Thread.sleep((int) (Math.random() * 1000));

} catch (InterruptedException e) {

e.printStackTrace();

}

public void setName(String name) {

this.name = name;

}

public String getName() {

return name;

}

測(cè)試代碼：

package com.bebig.producerconsumer;

//測(cè)試

public class ProducerAndConsumer {

/**

* @param args

public static void main(String[] args) {

Cart c = new Cart();

Producer p1 = new Producer(c, "Don");

Consumer c1 = new Consumer(c, "Scan");

Producer p2 = new Producer(c, "txc");

Consumer c2 = new Consumer(c, "Sun");

new Thread(p1).start();

new Thread(c1).start();

new Thread(p2).start();

new Thread(c2).start();

}

測(cè)試結(jié)果（隨機(jī)顯示）：

生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?