Java 實例 – 生產(chǎn)者/消費者問題

Java 實例 - 生產(chǎn)者/消費者問題

Java 實例

生產(chǎn)者和消費者問題是線程模型中的經(jīng)典問題：生產(chǎn)者和消費者在同一時間段內(nèi)共用同一個存儲空間，如下圖所示，生產(chǎn)者向空間里存放數(shù)據(jù)，而消費者取用數(shù)據(jù)，如果不加以協(xié)調(diào)可能會出現(xiàn)以下情況：

存儲空間已滿，而生產(chǎn)者占用著它，消費者等著生產(chǎn)者讓出空間從而去除產(chǎn)品，生產(chǎn)者等著消費者消費產(chǎn)品，從而向空間中添加產(chǎn)品。互相等待，從而發(fā)生死鎖。

以下實例演示了如何通過線程解決生產(chǎn)者/消費者問題：

/*
 author by w3cschool.cn
 ProducerConsumerTest.java
 */

public class ProducerConsumerTest {
   public static void main(String[] args) {
      CubbyHole c = new CubbyHole();
      Producer p1 = new Producer(c, 1);
      Consumer c1 = new Consumer(c, 1);
      p1.start(); 
      c1.start();
   }
}
class CubbyHole {
   private int contents;
   private boolean available = false;
   public synchronized int get() {
      while (available == false) {
         try {
            wait();
         }
         catch (InterruptedException e) {
         }
      }
      available = false;
      notifyAll();
      return contents;
   }
   public synchronized void put(int value) {
      while (available == true) {
         try {
            wait();
         }
         catch (InterruptedException e) { 
         } 
      }
      contents = value;
      available = true;
      notifyAll();
   }
}

class Consumer extends Thread {
   private CubbyHole cubbyhole;
   private int number;
   public Consumer(CubbyHole c, int number) {
      cubbyhole = c;
      this.number = number;
   }
   public void run() {
      int value = 0;
         for (int i = 0; i < 10; i++) {
            value = cubbyhole.get();
            System.out.println("消費者 #" + this.number+ " got: " + value);
         }
    }
}

class Producer extends Thread {
   private CubbyHole cubbyhole;
   private int number;

   public Producer(CubbyHole c, int number) {
      cubbyhole = c;
      this.number = number;
   }

   public void run() {
      for (int i = 0; i < 10; i++) {
         cubbyhole.put(i);
         System.out.println("生產(chǎn)者 #" + this.number + " put: " + i);
         try {
            sleep((int)(Math.random() * 100));
         } catch (InterruptedException e) { }
      }
   }
}

以上代碼運行輸出結(jié)果為：

消費者 #1 got: 0
生產(chǎn)者 #1 put: 0
生產(chǎn)者 #1 put: 1
消費者 #1 got: 1
生產(chǎn)者 #1 put: 2
消費者 #1 got: 2
生產(chǎn)者 #1 put: 3
消費者 #1 got: 3
生產(chǎn)者 #1 put: 4
消費者 #1 got: 4
生產(chǎn)者 #1 put: 5
消費者 #1 got: 5
生產(chǎn)者 #1 put: 6
消費者 #1 got: 6
生產(chǎn)者 #1 put: 7
消費者 #1 got: 7
生產(chǎn)者 #1 put: 8
消費者 #1 got: 8
生產(chǎn)者 #1 put: 9
消費者 #1 got: 9

Java 實例