ホームページ  >  記事  >  Java  >  Javaのプロデューサとコンシューマの例の詳細な説明

Javaのプロデューサとコンシューマの例の詳細な説明

Y2J
Y2Jオリジナル
2017-05-06 13:22:531789ブラウズ

この記事では、主に 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
[関連する推奨事項]

1.

Java 無料ビデオ チュートリアル

2.

Geek Academy Java ビデオ チュートリアル

3.

FastJson 開発チュートリアル

以上がJavaのプロデューサとコンシューマの例の詳細な説明の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明:
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。