指定されたスレッドでのJavaセマフォのインクリメント数

Question

誰かがこのコードをコンパイルした後に、なぜ何かを待っているスレッドがあると思いますか？ ID番号10,11,12のスレッドを1つずつ、50まで1つ増やしたい。 最終的には機能しますが、赤いボタン（終了）はまだ赤色です。つまり、まだプログラムが残っていますおそらく何かを待っています。

カウントが50の場合、リターンは動作し、メソッドから終了する必要があります。たぶんそれはありますが、十分ではありません。

public class App12 { 

    Semaphore sem1 = new Semaphore(1); 
    Semaphore sem2 = new Semaphore(0); 
    Semaphore sem3 = new Semaphore(0); 

    int count = 0; 

    public void inc() throws InterruptedException { 

     while (true) { 
      if (Thread.currentThread().getId() == 10) { 
       sem1.acquire(); 
       if (count != 50) { 
        count++; 
        System.out.println("Thread" + Thread.currentThread().getId() + " has incremented " + count); 

        sem2.release(); 
       } else 
        return; 
      } 

      if (Thread.currentThread().getId() == 11) { 
       sem2.acquire(); 
       if (count != 50) { 
        count++; 
        System.out.println("Thread" + Thread.currentThread().getId() + " has incremented " + count); 

        sem3.release(); 
       } else 
        return; 

      } 

      if (Thread.currentThread().getId() == 12) { 
       sem3.acquire(); 
       if (count != 50) { 
        count++; 
        System.out.println("Thread" + Thread.currentThread().getId() + " has incremented " + count); 

        sem1.release(); 
       } else 
        return; 

      } 
     } 
    } 

    public static void main(String[] args) { 

     App12 ap = new App12(); 
     for (int i = 0; i < 3; i++) { 
      Thread th1 = new Thread(new Runnable() { 
       public void run() { 
        try { 
         ap.inc(); 
         // dec3(); 

        } catch (InterruptedException e) { 
         // TODO Auto-generated catch block 
         e.printStackTrace(); 
        } 

       } 
      }); 
      th1.start(); 

     } 
    } 
} 

Answer 1

あなたの問題はあなたがスレッドでロックを解除したことがないということです、そして、彼らは永遠に待って終わる：

は、ここでは、コードです。あなたのロジックから

、あなたが50を打つ一度Bが戻っスレッド、しかしC.

を解除する解除を通します。スレッドBとCを解放しないでください。

したがって、必要なのは、他の待機スレッドをすべて解放する終了条件です。例えば

（あなたのwhileループで）：

if(count == 50) { 
       sem2.release(); 
       sem3.release(); 
       sem1.release(); 
      } 

問題は、彼らがリリースされるのを待っているsemathorにロックした時点で、11または12インクリメント後、彼らはimmidiatelly再びループに入るということです。あなたの数が50だった場合、それを解放するスレッドはあなたのif条件に入ることなく戻ります。

また、else節にリリースを追加できるので、すべてのスレッドが解放されるはずです。

アルトゥル

EDIT、

を役に立てば幸い：

public class App12 { 

    Semaphore sem1 = new Semaphore(1); 
    Semaphore sem2 = new Semaphore(0); 
    Semaphore sem3 = new Semaphore(0); 

    int count = 0; 

    public void inc() throws InterruptedException { 

     while (true) { 

      if (Thread.currentThread().getId() == 10) { 
       sem1.acquire(); 
       if (count != 50) { 
        count++; 
        System.out.println("Thread " + Thread.currentThread().getId() + " has incremented " + count); 
        sem2.release(); 
       } else { 
        sem2.release(); 
        return; 
       } 
      } 

      if (Thread.currentThread().getId() == 11) { 
       sem2.acquire(); 
       if (count != 50) { 
        count++; 
        System.out.println("Thread " + Thread.currentThread().getId() + " has incremented " + count); 
        sem3.release(); 
       } else { 
        sem3.release(); 
        return; 
       } 

      } 

      if (Thread.currentThread().getId() == 12) { 
       sem3.acquire(); 
       if (count != 50) { 
        count++; 
        System.out.println("Thread " + Thread.currentThread().getId() + " has incremented " + count); 
        sem1.release(); 
       } else { 
        sem1.release(); 
        return; 
       } 
      } 

     } 
    } 

    public static void main(String[] args) { 

     App12 ap = new App12(); 
     for (int i = 0; i < 3; i++) { 
      Thread th1 = new Thread(new Runnable() { 
       public void run() { 
        try { 
         ap.inc(); 
         // dec3(); 
         System.out.println("Exist "); 
        } catch (InterruptedException e) { 
         // TODO Auto-generated catch block 
         e.printStackTrace(); 
        } 

       } 
      }); 
      th1.start(); 
     } 
    } 
} 

注：カウントが50になると、私はsemathorsをリリースしていますので、ここで修正実装とのあなたの完全なコードがあります他のスレッドは終了できます。

Answer 2

ロックを解除してスレッドを終了します。

import java.util.concurrent.Semaphore; 

public class App12 { 

Semaphore sem1 = new Semaphore(1); 
Semaphore sem2 = new Semaphore(0); 
Semaphore sem3 = new Semaphore(0); 


int count = 0; 

public void inc() throws InterruptedException { 

    while (true) { 

     if (Thread.currentThread().getId() == 10) { 
      sem1.acquire(); 
      if (count != 50) { 
       count++; 
       System.out.println("Thread" + Thread.currentThread().getId() + " has incremented " + count); 

      } else { 
       sem2.release(); 
       return; 
      } 
      sem2.release(); 

     } 

     if (Thread.currentThread().getId() == 11) { 
      sem2.acquire(); 
      if (count != 50) { 
       count++; 
       System.out.println("Thread" + Thread.currentThread().getId() + " has incremented " + count); 

      } else { 
       sem3.release(); 
       return; 
      } 
      sem3.release(); 
     } 

     if (Thread.currentThread().getId() == 12) { 
      sem3.acquire(); 
      if (count != 50) { 
       count++; 
       System.out.println("Thread" + Thread.currentThread().getId() + " has incremented " + count); 

      } else { 
       sem1.release(); 
       return; 
      } 
      sem1.release(); 

     } 

    } 

} 

public static void main(String[] args) { 

    App12 ap = new App12(); 

    for (int i = 0; i < 3; i++) { 
     Thread th= new Thread(new Runnable() { 
      public void run() { 
       try { 
        ap.inc(); 
        // dec3(); 

       } catch (InterruptedException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
       } 

      } 
     }); 
     th.start(); 
    } 
} 
}