快捷導(dǎo)航

java解決單緩沖生產(chǎn)者消費(fèi)者問(wèn)題示例

更新時(shí)間：2014年04月27日 11:59:07 作者：

這篇文章主要介紹了java解單緩沖生產(chǎn)者消費(fèi)者問(wèn)題示例,需要的朋友可以參考下

經(jīng)典的生產(chǎn)者消費(fèi)者問(wèn)題模擬。此程序模擬最簡(jiǎn)單情形——單緩沖。為模擬實(shí)際情況，consume item和produce item時(shí)加了延時(shí)，可以通過(guò)修改延時(shí)模擬不同的生成消費(fèi)速率。

[code]

[/co/**
* single buffer consumer-producer problem.
* by xu(xusiwei1236@163.com).
* */
public class ConsumerProducer {

static Object buffer = null;

static Object mutex = new Object();

static Object condConsumer = new Object();

static Object condProducer = new Object();

public static void main(String[] args) {
  Thread producer = new Thread() {
   public void run() {
//    for(int i=0; i<10; i++) {
    for(int i=0; ; i++) {
     // produce item.
     try {
      Thread.sleep(1000);
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
     String item = new String("item-" + i);
     System.out.println("[producer] produced " + item);

     // wait for buffer empty.
     synchronized (condProducer) {
      while(buffer != null) {
       try {
        condProducer.wait();
       } catch (InterruptedException e) {
        e.printStackTrace();
       }
      }
     }

     // put item to buffer.
     synchronized (mutex) {
      buffer = item;
      System.out.println("[producer] put " + item + " to buffer.");
     }

     // notify consumers.
     synchronized (condConsumer) {
      condConsumer.notify();
     }
    }
   }
  };

  Thread consumer = new Thread() {
   public void run() {
//    for(int i=0; i<10; i++) {
    for( ; ; ) {
     // wait for item come.
     synchronized (condConsumer) {
      while( buffer == null ) {
       try {
        condConsumer.wait();
       } catch (InterruptedException e) {
        e.printStackTrace();
       }
      }
     }

     // get item from buffer.
     String item = null;
     synchronized (mutex) {
      item = (String)buffer;
      buffer = null;
      System.out.println(" [consumer] get " + item + " from buffer.");
     }

     // consume item.
     try {
      Thread.sleep(500);
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
     System.out.println(" [consumer] comsumed " + item);

     // notify producers.
     synchronized (condProducer) {
      condProducer.notify();
     }
    }
   }
  };

  consumer.start();
  producer.start();
}
}de]