Nur erste Thread eingeben, kann folgende Threads nicht eingeben

Question

Ich möchte Daten mit mehreren Threads verarbeiten, aber im Moment läuft nur der erste Thread, dann wird es vollständig gestoppt.

Ich versuche, die Namen der Threads auszudrucken, aber ich gebe nur den ersten Thread ein. Es stoppt nur, obwohl das Programm weiter läuft. Es geht um die synchpoint.await() stoppt dann.

public class Solver { 
    final int N; 
    final float[][] data; 
    final CyclicBarrier barrier; 

class Worker implements Runnable { 
    public int myRow; 
    String name; 
    public CyclicBarrier synchPoint; 

    Worker(CyclicBarrier barrier, int row, String name) { 
     myRow = row; 
     this.name = name; 
     this.synchPoint = barrier; 
     this.run(); 
    } 

    public void run() { 
      System.out.println("Name: " + name); 
      processRow(myRow); 
      mergeRows(); 

      try { 
       System.out.print("In SynchPoint"); 
       synchPoint.await(); 
      } catch (InterruptedException ex) { 
       return; 
      } catch (BrokenBarrierException ex) { 
       return; 
      } 
    } 
} 

public void processRow(int numRow){ 
    System.out.println("In Process Row"); 
} 

public void mergeRows(){ 
    System.out.println("In merge Row"); 
} 

public Solver(float[][] matrix) { 
    data = matrix; 
    N = matrix.length; 
    System.out.println("N: " + N); 
    Runnable barrierAction = 
      new Runnable() { public void run() { mergeRows(); }}; 
    barrier = new CyclicBarrier(N, barrierAction); 

    List<Thread> threads = new ArrayList<Thread>(N); 
    for (int i = 0; i < N; i++) { 
     String myName = "Worker-" + i; 
     Thread thread = new Thread(new Worker(barrier, i, myName)); 
     threads.add(thread); 
     thread.start(); 
     System.out.println("In loop, i is: " + i); 
    } 

    // wait until done 
    for (Thread thread : threads) 
     try { 
      thread.join(); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
    } 

    public static void doWork(){ 
     float[][] matrix2 = new float[6][2000]; 
     Solver solve = new Solver(matrix2); 
    } 

    public static void main(String[] args) { 
     Solver.doWork(); 
    } 
} 

Output:

N: 5
Name: Worker-0
In Process Row
Row ist: 0
Datenlänge: 5
In merge Row
In Zusammenführungszeile
In SynchPoint

Answer 1

Sie haben eine unangenehme Angewohnheit, Ihre Konstruktoren dazu zu bringen, anders als eine Instanz zu initialisieren. Es ist letztlich nicht schädlich, dass der Konstruktor Solver dies tut, aber die Tatsache, dass Solver.Worker die run() Methode der Instanz aufruft, ist die Quelle Ihres Problems.

Sie führen den Worker-Konstruktor im Hauptthread der Anwendung aus. Dieser Konstruktor ruft run() auf, wodurch der Thread ausgesetzt wird, wenn er synchPoint.await() erreicht. Der Thread würde fortgesetzt, wenn genügend andere Threads diesen Punkt erreichen, aber keiner wird jemals, weil der eine Thread, der getan hat, derjenige ist, der die anderen erstellt und gestartet hätte, und er kann nicht fortfahren.

Entfernen Sie die this.run() von Worker Konstruktor und Sie sollten viel weiter bekommen.