Wie pausiere ich Schleife, während Multithreading lebt

Question

Ich habe 3 Threads, die innerhalb einer Schleife aufgerufen werden.

For i As Integer = 0 To DG.Rows.Count - 1 
    Dim thread1 = New System.Threading.Thread(AddressOf processData) 
    Dim thread2 = New System.Threading.Thread(AddressOf processData2) 
    Dim thread3 = New System.Threading.Thread(AddressOf processData3) 
    If Not thread1.IsAlive Then 
     x1 = i 
     thread1.Start() 
    ElseIf Not thread2.IsAlive Then 
     x2 = i 
     thread2.Start() 
    ElseIf Not thread3.IsAlive Then 
     x3 = i 
     thread3.Start() 
    End If 
Next 

Wie pausiere ich die Schleife, während alle Threads leben? Was ich will, ist, wenn einer der Threads beendet ist, dann die Schleife fortsetzen und die (i), dann pausieren Sie die Schleife erneut, wenn es keine verfügbaren Threads gibt. Weil manchmal DG.Rows Artikel mehr als 3 sind.

Answer 1

Ich denke, du willst so etwas machen. Nicht pausieren, nur einen Thread pro Schleifeniteration starten.

For i As Integer = 0 To DG.Rows.Count - 1 
    Dim thread1 = New System.Threading.Thread(AddressOf processData) 
    thread1.Start(i) 
Next 

Aber in jedem Fall, ich glaube nicht, dass Sie new System.Threading.Thread in jeder Schleife anrufen möchten. Diese sollten außerhalb der For-Schleife verschoben werden.

Answer 2

Lassen Sie das Framework dies für Sie behandeln: Verwenden Sie die ThreadPool.

Zuerst ein Array erstellen, um Thread-Status für jede Position zu halten:

Dim doneEvents(DG.Rows.Count) As ManualResetEvent 

Wie das x1, x2, Variablen, muss diese sowohl von Ihrem Haupt-Thread und das processData Verfahren zugänglich sein.

ändern Sie dann Ihre processData Methode ein Object Argument am Anfang zu übernehmen und ein Resetevent am Ende gesetzt:

Public Sub processData(ByVal data As Object) 
    Dim x As Integer = CInt(data) 

    '... 
    'Existing code here 

    doneEvents(x).Set() 
End Sub 

Jetzt können Sie sie nur Warteschlange alle so zusammen:

For i As Integer = 0 To DG.Rows.Count - 1 
    ThreadPool.QueueUserWorkItem(processData, i) 
Next 
WaitHandle.WaitAll(doneEvents) 
Console.WriteLine("All data is processed.") 

Obwohl ich vermute, dass Sie auch die Daten aus Ihrem Raster für jede Zeile an die Methode processData übergeben sollten.

Sie können auch die neueren Async/Await Schlüsselwörter verwenden, aber ich werde es schwer haben, ein Beispiel dafür zu schreiben, ohne etwas über den Inhalt von processData zu wissen.

Answer 3

Es könnte sein, dass Sie Parallel Methoden TPL die Nutzung der Code wie folgt schreiben:

Parallel.For(_ 
    0, _ 
    DG.Rows.Count, _ 
    New ParallelOptions() With {.MaxDegreeOfParallelism = 3}, _ 
    Sub(i) processData(i)) 

Ich verstehe nicht, warum Sie processData haben, processData2 und processData3 though.