Java 예제 - 생산자/소비자 문제

생산자와 소비자 문제는 스레드 모델의 전형적인 문제입니다. 생산자와 소비자는 동일한 기간 동안 동일한 저장 공간을 공유합니다. 아래 그림에서 볼 수 있듯이 생산자는 해당 공간에 데이터를 저장하고 소비자는 검색합니다. 데이터를 사용하다가 조율이 안되면 다음과 같은 상황이 발생할 수 있습니다.

저장공간이 꽉 차서 생산자가 점유하고 있는데, 소비자는 생산자가 제품을 치울 공간을 마련해주기를 기다리고 있습니다. , 생산자는 소비자를 기다리며 제품을 소비하고, 이를 통해 공간에 제품을 추가한다. 서로 기다리다가 교착 상태가 발생합니다.

다음 예는 스레드를 통해 생산자/소비자 문제를 해결하는 방법을 보여줍니다.

/*
 author by w3cschool.cc
 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("生产者 #" + this.number + " put: " + i);
         try {
            sleep((int)(Math.random() * 100));
         } catch (InterruptedException e) { }
      }
   }}

위 코드의 출력 결과는 다음과 같습니다.

消费者 #1 got: 0
生产者 #1 put: 0
生产者 #1 put: 1
消费者 #1 got: 1
生产者 #1 put: 2
消费者 #1 got: 2
生产者 #1 put: 3
消费者 #1 got: 3
生产者 #1 put: 4
消费者 #1 got: 4
生产者 #1 put: 5
消费者 #1 got: 5
生产者 #1 put: 6
消费者 #1 got: 6
生产者 #1 put: 7
消费者 #1 got: 7
生产者 #1 put: 8
消费者 #1 got: 8
生产者 #1 put: 9
消费者 #1 got: 9

위 내용은 Java 예제입니다 - 생산자/소비자 문제 관련 내용은 PHP 중국어 홈페이지(www.php.cn)를 참고해주세요!