Ausführen von Threads in einer Sequenz mit Semaphoren

Question

Ich möchte einige Threads in einer Sequenz mit Semaphoren ausführen. Es gibt kein Problem mit einem Semaphor für jeden Thread, aber ich würde es gerne mit nur einem verwenden.

Ich denke, dass der folgende Code gut funktionieren sollte, aber manchmal nicht. Ich würde deine Hilfe schätzen.

package pruebasecuencia; 

import java.util.concurrent.Semaphore; 

public class PruebaSecuencia { 
    Semaphore sem = new Semaphore(0); 

    public void go() throws InterruptedException{ 
     final int N = 5; 

     Process[] proc = new Process[N]; 

     for (int i = 0; i < proc.length; i++) { 
      proc[i] = new Process(i, sem); 
      proc[i].start(); 
     } 

     for (int i = 0; i < proc.length; i++) { 
      proc[i].join(); 
     } 
     System.out.println("Ended simulation"); 
    } 

    public static void main(String[] args) throws InterruptedException { 
     new PruebaSecuencia().go(); 
    } 
} 


public class Process extends Thread{ 
    Semaphore sem; 
    int id; 

    public Process (int id, Semaphore sem){ 
     this.id = id; 
     this.sem = sem; 
    } 

    @Override 
    public void run(){ 
     try { 
      sem.acquire(id); 
      System.out.println("Process " + id + " executing"); 
      sleep (300); 
      sem.release(id+1); 
     } catch (InterruptedException ex) { 
      Logger.getLogger(Proceso.class.getName()).log(Level.SEVERE, null, ex); 
    } 
} 

}

Answer 1

this answer sehen, dass erklärt, warum es fehlschlagen kann, beispielsweise wenn es nur drei Genehmigungen zur Verfügung und der Faden vier Genehmigungen erfordert, ist die nächste zugewiesen erlaubt sein. Darüber hinaus werden verschiedene Möglichkeiten für dieses Problem erläutert.