Probleme mit Parallel.For

  • VB.NET
  • .NET (FX) 4.0

Es gibt 30 Antworten in diesem Thema. Der letzte Beitrag () ist von oobdoo.

    @oobdoo Zunächst muss die Schleife, die Du parallelisieren willst, in einer "normalen" For-Schleife funktionieren.
    Packe dazu den Code aus der anonymen Methode in eine "echte" Methode und bring sie zum Laufen.
    Danach stellst Du das auf Parallel.For um.
    Falls Du diesen Code kopierst, achte auf die C&P-Bremse.
    Jede einzelne Zeile Deines Programms, die Du nicht explizit getestet hast, ist falsch :!:
    Ein guter .NET-Snippetkonverter (der ist verfügbar).
    Programmierfragen über PN / Konversation werden ignoriert!

    Das hatte ich doch schon seit Post #3 gemacht. Zwei Methoden die beide das gleiche bewirken sollen. Schleifen1 mit den normalen For-Schleifen, was funktioniert, und die Methode Schleifen2 worin meine Versuche stecken die gleiche Wirkweise wie von Schleifen1 zu bekommen.
    Aktuelles Projekt: Z80 Disassembler für Schneider/Amstrad CPC :love:

    oobdoo schrieb:

    Das hatte ich doch schon seit Post #3 gemacht.
    Hast Du nicht:

    VB.NET-Quellcode

    1. Dim result = Parallel.[For](0, 1000, ergebnis1 = TuWas("a", i1))
    In TuWas() müsste dann dies alles drin stecken:

    VB.NET-Quellcode

    1. For i2 = 0 To 1000
    2. ergebnis2 = TuWas("b", i2)
    4. For i3 = 0 To 1000
    5. ergebnis3 = TuWas("c", i3)
    7. ergebnis = Trim(ergebnis1 + ergebnis2 + ergebnis3)
    8. If ergebnis = habenwill Then
    9. tuwasanderes(ergebnis)
    10. Exit Sub
    11. End If
    13. Next
    14. Next
    ############################
    Dein Quellcode müsste so aussehen:
    Spoiler anzeigen

    VB.NET-Quellcode

    1. Sub Schleifen2()
    2. Parallel.[For](0, 1000, AddressOf TueNochWas)
    3. End Sub
    5. Sub TueNochWas(i1 As Integer)
    6. ergebnis1 = TuWas("a", i1)
    8. For i2 = 0 To 1000
    9. ergebnis2 = TuWas("b", i2)
    10. For i3 = 0 To 1000
    11. ergebnis3 = TuWas("c", i3)
    13. ergebnis = Trim(ergebnis1 + ergebnis2 + ergebnis3) ' <<<<<<<<<<<<<<<<<<<<
    14. If ergebnis = habenwill Then
    15. tuwasanderes(ergebnis)
    16. Exit Sub
    17. End If
    18. Next
    19. Next
    20. End Sub
    Und wenn ich mir die markierte Zeile ansehe, muss ich Dir sagen, dass Dein Problem so nicht parallelisierbar ist, weil die Umläufe abhängig voneinander sind, die müssen unabhängig voneinander sein. Sorry.

    Falls Du diesen Code kopierst, achte auf die C&P-Bremse.
    Jede einzelne Zeile Deines Programms, die Du nicht explizit getestet hast, ist falsch :!:
    Ein guter .NET-Snippetkonverter (der ist verfügbar).
    Programmierfragen über PN / Konversation werden ignoriert!

    Dieser Beitrag wurde bereits 1 mal editiert, zuletzt von „RodFromGermany“ ()

    garnet. Also an den Schleifen kannste nix verbessern.
    Massgeblich in dem Fall ist der Code in der innersten Schleife - ob man da was effizienteres formulieren kann.

    Oder man untersucht die Daten nochmal neu. Oft kann man aus dem Fehlschlag eines Zwischenergebnisses ableiten, dass man den ganzen Weg - mit evtl 1000 weiteren Permutationen - garnet weiterverfolgen muss - Stichwort Backtracking.
    Oder vielleicht sind die Daten iwie in eine ssortierte Ordnung zu bringen - da kann man dann meist auch enorm Effizienz gewinnen.

    Jo, mit deine 3 Schleifen kann man auch Backtracking anwenden:
    Wenn sich in der äussersten schleife schon zeigt, dass der erste Teil von habenwill nicht matcht, dann kann man die inneren schleifen gleich überspringen. Performance-Gewinn von ca 100.000%

    Mit Parallel.For komme ich also nicht weiter. Da dachte ich mir ich versuche es mit Multithreading. Klappt aber auch nicht, weil kein Ereignis durch RaiseEvent ausgelöst wird.

    Anbei der Code. Das gesuchte wird in der 3er Schleife gefunden. Dann soll ein Event erzeugt werden, auf welches ich im Hauptprogramm reagieren kann. Geplant hatte ich, dort den Thread abzubrechen. Aber so weit bin ich gar nicht gekommen, weil eben kein Event ankommt. Wo liegt der (Denk)Fehler?

    Hauptprogramm:
    Spoiler anzeigen

    VB.NET-Quellcode

    1. Option Strict On
    3. Imports System
    4. Imports System.Threading
    5. Imports System.Threading.Tasks
    6. Imports System.Text.StringBuilder
    8. Public Class ParallelTest3
    10. Public maxwert As Integer = 20
    11. Public rückgabe As String
    12. Public habenwill As String = "a1 b2 c3"
    14. Public WithEvents m As multi
    16. Public Sub New()
    17. Debug.Flush()
    18. meintask()
    19. End Sub
    21. Public Sub meintask()
    22. Dim mythread As Threading.Thread
    23. Dim m As multi = New multi(maxwert, 1, habenwill)
    25. mythread = New Thread(AddressOf m.schleife)
    27. mythread.Start()
    28. End Sub
    30. Public Sub multidone(obj As Object, result As String) Handles m.done
    31. Dim s As String = result
    33. 'mythread.Abort()
    34. MsgBox(s)
    35. End Sub
    37. End Class


    Unterprogramm:
    Spoiler anzeigen

    VB.NET-Quellcode

    1. Option Strict On
    3. Public Class multi
    5. Public maxwert As Integer
    6. Public verzögerung As Integer
    7. Public gesucht As String
    8. Public gefunden As String
    10. Public Event done(obj As Object, gefunden As String)
    11. Public Sub New(m As Integer, v As Integer, g As String)
    12. maxwert = m
    13. verzögerung = v
    14. gesucht = g + " "
    15. End Sub
    17. Public Sub schleife()
    18. Dim ergebnis As String
    19. Dim ergebnis1 As String
    20. Dim ergebnis2 As String
    21. Dim ergebnis3 As String
    23. For i1 = 0 To maxwert
    24. ergebnis1 = TuWas("a", i1)
    26. For i2 = 0 To maxwert
    27. ergebnis2 = TuWas("b", i2)
    29. For i3 = 0 To maxwert
    30. ergebnis3 = TuWas("c", i3)
    32. ergebnis = ergebnis1 + ergebnis2 + ergebnis3
    34. If ergebnis = gesucht Then
    35. gefunden = ergebnis
    36. Debug.WriteLine(ergebnis)
    37. Debug.WriteLine(" gefunden...")
    38. RaiseEvent done(Me, gefunden)
    39. Else
    40. Debug.WriteLine(ergebnis)
    41. End If
    42. 'Threading.Thread.Sleep(verzögerung)
    43. Next
    44. Next
    45. Next
    47. End Sub
    49. Public Function TuWas(s As String, i As Integer) As String
    50. Return s + i.ToString + " "
    51. End Function
    53. End Class
    Aktuelles Projekt: Z80 Disassembler für Schneider/Amstrad CPC :love:

    Jetzt scheint es mit dem Event doch zu klappen. 8o
    Dann kann ich mich morgen darum kümmern wie ich sauber den Thread beenden kann.

    Schonmal Danke an alle die mir bis hierher geholfen haben. :)

    Hauptprogramm
    Spoiler anzeigen

    VB.NET-Quellcode

    1. Option Strict On
    3. Imports System
    4. Imports System.Threading
    5. Imports System.Threading.Tasks
    6. Imports System.Text.StringBuilder
    8. Public Class ParallelTest3
    10. Public mythread As Threading.Thread
    12. Public maxwert As Integer = 20
    13. Public rückgabe As String
    14. Public habenwill As String = "a1 b2 c3"
    16. Public WithEvents m As multi
    18. Public Sub New()
    19. Debug.Flush()
    20. meintask()
    21. End Sub
    23. Public Sub meintask()
    24. m = New multi(maxwert, 1, habenwill)
    25. mythread = New Thread(Sub() m.schleife())
    26. mythread.Start()
    27. End Sub
    29. Public Sub multidone(obj As Object, result As String) Handles m.done
    30. Dim s As String = result
    32. 'mythread.Suspend()
    33. MsgBox(s)
    34. End Sub
    36. End Class


    Unterprogramm
    Spoiler anzeigen

    VB.NET-Quellcode

    1. Option Strict On
    3. Public Class multi
    5. Public maxwert As Integer
    6. Public verzögerung As Integer
    7. Public gesucht As String
    8. Public gefunden As String
    10. Public Event done(obj As Object, gefunden As String)
    11. Public Sub New(m As Integer, v As Integer, g As String)
    12. maxwert = m
    13. verzögerung = v
    14. gesucht = g + " "
    15. End Sub
    17. Public Sub schleife()
    18. Dim ergebnis As String
    19. Dim ergebnis1 As String
    20. Dim ergebnis2 As String
    21. Dim ergebnis3 As String
    23. For i1 = 0 To maxwert
    24. ergebnis1 = TuWas("a", i1)
    26. For i2 = 0 To maxwert
    27. ergebnis2 = TuWas("b", i2)
    29. For i3 = 0 To maxwert
    30. ergebnis3 = TuWas("c", i3)
    32. ergebnis = ergebnis1 + ergebnis2 + ergebnis3
    34. If ergebnis = gesucht Then
    35. gefunden = ergebnis
    36. Debug.WriteLine(ergebnis)
    37. Debug.WriteLine(" gefunden...")
    38. RaiseEvent done(Me, gefunden)
    39. 'Exit Sub
    40. Else
    41. Debug.WriteLine(ergebnis)
    42. End If
    43. 'Threading.Thread.Sleep(verzögerung)
    44. Next
    45. Next
    46. Next
    48. End Sub
    50. Public Function TuWas(s As String, i As Integer) As String
    51. Return s + i.ToString + " "
    52. End Function
    54. End Class
    Aktuelles Projekt: Z80 Disassembler für Schneider/Amstrad CPC :love:

    oobdoo schrieb:

    gesucht = g + " "
    Ist das mit dem Leerzeichen am Ende korrekt?
    In Deinem ergebnis kommt keins vor.

    oobdoo schrieb:

    Geplant hatte ich, dort den Thread abzubrechen.

    oobdoo schrieb:

    Dann kann ich mich morgen darum kümmern wie ich sauber den Thread beenden kann.
    Ein Thread wird abgebrochen, indem die Thread-Prozedur verlassen wird, einfach Return und feddich.
    Das evenmt signalisiert dem Hauptprogramm dann nur noch die Beendigung des Threads.
    Falls Du diesen Code kopierst, achte auf die C&P-Bremse.
    Jede einzelne Zeile Deines Programms, die Du nicht explizit getestet hast, ist falsch :!:
    Ein guter .NET-Snippetkonverter (der ist verfügbar).
    Programmierfragen über PN / Konversation werden ignoriert!

    nocheinmal: Du kannst mit Backtrackingg die Performance exorbitant beschleunigen.
    In deim Fall konkret bedeutet das: Prüfe das Teilergebnis Ergebnis1. Wenn das nicht akzeptabel ist, kannste dir die inneren Schleifen komplett sparen.
    Dasselbe gilt für Ergebnis2.
    Threading wirstedann wohl nicht mehr brauchen.

    Doch, Threading wird gebraucht (Kenntnisstand jetzt).

    Meine Anfrage im Forum war allgemein gehalten. Im eigentlichen Projekt sieht es im Code komplizierter aus, daher hatte ich bei der Anfrage ein einfaches Code Beispiel verwendet. Durch eure Antworten hab ich das Thema Threading/Parallel.For besser verstanden. Resultat: Im eigentlichen Projekt mit Threading schneller am Ziel (0.xxx Sekunden) als mit den verschachtelten For/Next Schleifen (>6 Sekunden). Damit kann ich in meinem Projekt weiterarbeiten.
    Aktuelles Projekt: Z80 Disassembler für Schneider/Amstrad CPC :love:

    Dieser Beitrag wurde bereits 2 mal editiert, zuletzt von „oobdoo“ ()

Facebook
Telefonspende