生產者消費者例項

package com.rx.thread.produce.consume;

public

class product

public

void setid(string id)

public product(string id)

public string tostring()

public

static

void main(string args) }

package com.rx.thread.produce.consume;

public

class store

/** 倉庫中的產品 */

private product product = null;

public product getproduct()

public

void setproduct(product product)

/** 顯示當前倉庫狀態是否滿 */

private boolean empty = true;

/***

* 放置產品

* @param product 放置的產品，可以抽象出來，放置任意物品

*/public

void putproduct(product product) catch (interruptedexception e)

}empty = false;

this.product = product;

system.out.println(thread.currentthread().getname() + " put product : " + product.getid());

//notify();

this.notifyall();}}

/***

* 取出產品

* @return 取出的產品

* @throws interruptedexception

*/public synchronized product takeoutproduct() catch (interruptedexception e)

}system.out.println(thread.currentthread().getname() + " take out product : "+ product.getid());

empty = true;

//notify();

this.notifyall();

return

this.product;}}

package com.rx.thread.produce.consume;

public

class produce implements runnable

public

void run() catch (interruptedexception e) }}

} package com.rx.thread.produce.consume;

public

class consume implements runnable

public

void run()

}system.out.println("end.");}}

package com.rx.thread.produce.consume;

public

class test }

thread-0 put product : 0

thread-1 take out product : 0