マルチスレッドを使用して2つのWebサービスを集計するにはどうすればよいですか？

Question

リアルタイムインベントリを提供するアプリケーションには、2つのWebサービスが実行されています。私は、これらの2つのインターフェイスから在庫を読み取り、総在庫を計算するJavaマルチスレッドプログラムを書く必要があります。

事前条件：両方のスレッドを遅滞なく開始する必要があります。

以下のコードを使用してこの問題に近づいてみました。これが正しいかどうかを確認してお知らせください。利用可能な別のアプローチもあります。

package com.app.thread; 

public class InventoryThread { 

    public static void main(String a[]) throws InterruptedException { 

     Inventory inv = new Inventory(); 
     InventoryInterface1 i1 = new InventoryInterface1(inv); 
     InventoryInterface2 i2 = new InventoryInterface2(inv); 

     Thread t1 = new Thread(i1, "T1"); 
     Thread t2 = new Thread(i2, "T2"); 

     t1.start(); 
     t2.start(); 

     t1.join(); 
     t2.join(); 

     System.out.println(inv.getInventory()); 
    } 
} 

class Inventory { 

    private long inventory; 

    public long getInventory() { 
     return inventory; 
    } 

    public void setInventory(long inventory) { 
     this.inventory = inventory; 
    } 
} 

class InventoryInterface1 implements Runnable { 

    private Inventory inv; 

    public InventoryInterface1(Inventory inv) { 
     this.inv = inv; 
    } 

    public void run() { 
     System.out.println(Thread.currentThread().getName() + " running"); 
     synchronized (inv) {    
      System.out.println(Thread.currentThread().getName() + " updates inventory"); 
      inv.setInventory(inv.getInventory() + 100);   
     } 
    } 
} 

class InventoryInterface2 implements Runnable { 
    private Inventory inv; 

    public InventoryInterface2(Inventory inv) { 
     this.inv = inv; 
    } 

    public void run() { 
     System.out.println(Thread.currentThread().getName() + " running"); 
     synchronized (inv) { 
      try { 
       System.out.println(Thread.currentThread().getName() + " waiting.."); 
       while(inv.getInventory() <= 0){ 
        inv.wait(); 
       }    
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } 
      System.out.println(Thread.currentThread().getName() + " updates inventory"); 
      inv.setInventory(inv.getInventory() + 200); 
      System.out.println(Thread.currentThread().getName() + " notifies"); 
      inv.notifyAll(); 
     } 
    } 
} 

Answer 1

変更Inventory.inventory。あなたは文句を言わないInventoryInterface1 & InventoryInterface2

class Inventory { 

    private AtomicLong inventory = new AtomicLong(); 

    public long getInventory() { 
     return inventory.longValue(); 
    } 

    public void incrementInventory(long inventory) { 
     inventory.addAndGet(inventory); 
    } 
} 

問題にInventoryインスタンス上のsyncronizationを必要とするその方法は、それが読み込み、Javaでlongにアトミックである必要はありません書き込みです。 AtomicLongのaddAndGetはアトミックな操作です。ここで

は、私はあなたが最初の同時実行のチュートリアルを読むことをお勧めしたい

class InventoryInterface1 implements Runnable { 

    private Inventory inv; 

    public InventoryInterface1(Inventory inv) { 
     this.inv = inv; 
    } 

    public void run() { 
     System.out.println(Thread.currentThread().getName() + " running"); 
     System.out.println(Thread.currentThread().getName() + " updates inventory"); 
     inv.incrementInventory(100);   

    } 
} 



    class InventoryInterface2 implements Runnable { 

    private Inventory inv; 

    public InventoryInterface2(Inventory inv) { 
     this.inv = inv; 
    } 

    public void run() { 
     System.out.println(Thread.currentThread().getName() + " running"); 
     System.out.println(Thread.currentThread().getName() + " updates inventory"); 
     inv.incrementInventory(200); 
    } 
} 

Answer 2

一つだけが一度にアクティブにできるので、あなたのRunnableスレッドの両方が彼らの全体の実行のために同期されている場合は、マルチスレッドのパフォーマンスの改善が見られるかどうかはわかりません。しかし、一般的なアプローチは正しく見えますが、実際に共有メモリにアクセスしているときに同期を制限しようとします。

更新

あなたも、スレッドの一つが、同期ロックを保持してもロックが解放されるまで実行できない他のスレッドを待っているデッドロック状態を有していても良いように見えます。あなたはinv.wait()を呼び出す前にロックを解除することができますが、実際にはinvへのアクセスの周りでより精細な同期を使用するだけです。

どのスレッドが最初に実行されるかは実際気になりますか？マルチスレッドを使用したくない場合は、wait()をInventoryInterface2から削除する可能性があります。 AtomicLongへ

class InventoryInterface2 implements Runnable { 
    private Inventory inv; 

    public InventoryInterface2(Inventory inv) { 
     this.inv = inv; 
    } 

    public void run() { 
     System.out.println(Thread.currentThread().getName() + " running"); 
     synchronized (inv) { 
     System.out.println(Thread.currentThread().getName() + " updates inventory"); 
     inv.setInventory(inv.getInventory() + 200); 
     System.out.println(Thread.currentThread().getName() + " notifies"); 
     inv.notifyAll(); 
    } 

}