ここでは、この方法がどのように機能するかを示す最も一般的な例の 1 つを示します。店舗、生産者、消費者がいるとします。メーカーは生産製品の一部を店舗に移し、その後消費者がそれらを手に入れることができます。メーカーがそれぞれ 8 つの商品を生産しなければならないとすると、消費者はそれらをすべて購入しなければなりません。ただし、同時に倉庫に入れることができるアイテムは 6 つまでです。この問題を解決するには、 wait()メソッドとnotify()メソッドを使用します。マーケット、メーカー、クライアントの3 つのクラスを定義しましょう。run()メソッドの製造元は、そのメソッドを使用して8 つの製品をMarketオブジェクトに追加します。put()メソッド。クライアントはループ内のrun()メソッドでMarketオブジェクトの get メソッドを呼び出して、これらの商品を取得します。Marketクラスの put メソッドと get メソッドは同期されます。Marketクラス内の商品の存在を追跡するには、item 変数の値をチェックします。製品を取得するget ()メソッドは、製品が少なくとも 1 つある場合にのみ起動する必要があります。そのため、getメソッドでは商品が欠落しているかどうかを確認します。項目が利用できない場合は、wait()メソッドが呼び出されます。このメソッドはMarketオブジェクトのモニターを解放し、 notify()が実行されるまで get メソッドをブロックします。メソッドは同じモニター上で呼び出されます。put()メソッドで項目が追加され、 notify() が呼び出されると、get()メソッドがモニターを取得します。その後、クライアントは商品を受け取ります。これを行うには、メッセージが表示され、項目の値が減ります。最後に、notify()メソッド呼び出しはput()メソッドに続行するよう通知します。put()メソッドでも同様のロジックが機能しますが、Marketに製品が 6 個以下の場合にのみput()メソッドが機能します。
class Market {
private int item = 0;
public synchronized void get() {
//here we use wait() method
while (item < 1) {
try {
wait();
}
catch (InterruptedException e) {
}
}
item--;
System.out.println("A client has bought 1 item...");
System.out.println("Items quantity in Market warehouse... " + item);
notify();
}
public synchronized void put() {
//here we use wait() method when the Warehouse is full
while (item >= 6) {
try {
wait();
}
catch (InterruptedException e) {
}
}
item ++;
System.out.println("Manufacturer has added 1 more item...");
System.out.println("Now there are " + item + " items in Warehouse" );
notify();
}
}
class Manufacturer implements Runnable {
Market market;
Manufacturer(Market market) {
this.market = market;
}
public void run() {
for (int i = 0; i < 8; i++) {
market.put();
}
}
}
class Client implements Runnable {
Market market;
Client(Market market) {
this.market = market;
}
public void run() {
for (int i = 0; i < 8; i++) {
market.get();
}
}
}
//wait() method test class
public class WaitTest {
public static void main(String[] args) {
Market market = new Market();
Manufacturer manufacturer = new Manufacturer(market);
Client client = new Client(market);
new Thread(manufacturer).start();
new Thread(client).start();
}
}
GO TO FULL VERSION