Java 線程生產(chǎn)者/消費者

Java線程教程 - Java線程生產(chǎn)者/消費者

生產(chǎn)者/消費者是使用wait()和notify()方法的典型線程同步問題。

例子

有四個類：緩沖區(qū)，生產(chǎn)者，消費者和生產(chǎn)者CumerumerTest。

Buffer類的一個對象具有一個整數(shù)數(shù)據(jù)元素，它將由生產(chǎn)者生成并由消費者消費。

我們必須同步對緩沖區(qū)的訪問，因此只有當緩沖區(qū)為空時，生產(chǎn)者才產(chǎn)生一個新的數(shù)據(jù)元素，而消費者只有在可用時才消耗緩沖區(qū)的數(shù)據(jù)。

ProducerConsumerTest類用于測試程序。

import java.util.Random;

class Consumer extends Thread {
  private Buffer buffer;

  public Consumer(Buffer buffer) {
    this.buffer = buffer;
  }

  public void run() {
    int data;
    while (true) {
      data = buffer.consume();
    }
  }
}

public class Main {
  public static void main(String[] args) {
    Buffer buffer = new Buffer();
    Producer p = new Producer(buffer);
    Consumer c = new Consumer(buffer);

    p.start();
    c.start();
  }
}

class Producer extends Thread {
  private Buffer buffer;

  public Producer(Buffer buffer) {
    this.buffer = buffer;
  }

  public void run() {
    Random rand = new Random();
    while (true) {
      int n = rand.nextInt();
      buffer.produce(n);
    }
  }
}

class Buffer {
  private int data;
  private boolean empty;

  public Buffer() {
    this.empty = true;
  }

  public synchronized void produce(int newData) {
    while (!this.empty) {
      try {
        this.wait();
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
    this.data = newData;
    this.empty = false;
    this.notify();
    System.out.println("Produced:" + newData);
  }

  public synchronized int consume() {
    while (this.empty) {
      try {
        this.wait();
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
    this.empty = true;
    this.notify();
    System.out.println("Consumed:" + data);
    return data;
  }
}

上面的代碼生成以下結果。