Ende aller Threads

  • VB.NET

Es gibt 24 Antworten in diesem Thema. Der letzte Beitrag () ist von Kraizy.

    Naja eine Endlosschleife ist da ja nicht eingebaut..
    erst einmal die Frage was willst Du beenden und warum überhaupt ? Willst Du alle Threads beenden ( aus irgendwelchen Gründen) so wirst Du dir alle gestarteten Threads irgendwo ( z.B. einer Liste merken müssen) um sie später auchs stopnne zu können. Momentan merkst Du Dir in der Variable _thread nur den letzten ...

    Naja, der Benutzer fügt in eine ListBox/View seine Daten ein (diese werden dann in _list gespeichert) und drückt auf den Start-Button. Dann werden immer 5 Einträge daraus gleichzeitig genommen und z.B. als Parameter für die "Login"-Funktion aus der DLL übergeben. Und das ganze, wie bereits gesagt, eben so lange, bis alle Einträge durch sind. Der Benutzer soll jedoch die Möglichkeit haben, diesen Prozess zwischenzeitlich stoppen zu können, sodass er nicht unbedingt warten muss, bis alle Einträge komplett durch sind. Deshalb das Abort(), was aber wohl keine gute Lösung war..deswegen würde ich nun gerne wissen, wie ich das anders machen soll. Ein kleines Beispiel würde mir da ziemlich helfen..

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

    Da Du anscheinend schon eine externe API für den Webrequest verwendest, wir der Vorschlag für einen asynchronen WR wohl eher unrealistisch sein.

    Kraizy schrieb:

    Der Benutzer soll jedoch die Möglichkeit haben, diesen Prozess zwischenzeitlich stoppen zu können, sodass er nicht unbedingt warten muss, bis alle Einträge komplett durch sind. Deshalb das Abort(), was aber wohl keine gute Lösung war..deswegen würde ich nun gerne wissen, wie ich das anders machen soll.

    Für einen harten Abbruch kannst Du ohne weiteres Abort verwenden, nur solltest Du die auftretende Exception dann auch sauber abfangen. Nur sollten dann alle laufenden Threads und nicht nur der letzte gestoppt werden.

    Das folgende zusammegehackte Beispiel wird bestimmt keinen Beauty Contest gewinnen, aber vielleicht bekommst Du ja ein paar Ideen wie Du das verbessern könntest. Es können durchaus noch Fehler enthalten sein:

    Beispielcode

    VB.NET-Quellcode

    1. Imports System.Threading
    2. Public Class Form1
    3. Dim WithEvents sendRequests As New sendRequests
    4. Private Sub Button1_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Click
    5. sendRequests.send(New List(Of String)({"blubb1", "blubb2", "blubb3", "blubb4", "blubb5", "blubb6", "blubb7", "blubb8"}))
    6. End Sub
    8. Public Sub complete() Handles sendRequests.SendCompleted
    9. MessageBox.Show("done")
    10. End Sub
    12. Private Sub Button2_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button2.Click
    13. sendRequests.Stop()
    14. End Sub
    15. End Class
    17. ' class sendRequests
    18. Public Class sendRequests
    19. ' Public properties
    20. Const maxThreadCount = 5 ' Anzahl erlaubter paralleler Prozesse ( kann natürlich geändert werden)
    21. Public Event SendCompleted() ' wird ausgelöst wenn die Verarbeitung aller strings fertig ist
    23. ' private
    24. Private runningThreads As New List(Of Threading.Thread) ' liste der aktuell laufenden threads
    25. Private workItems As New List(Of String) ' liste der strings die noch zur Verarbeitung anstehen
    26. Private Event threadCompleted(ByVal t As Thread, ByVal s As String, ByVal success As Boolean) ' event beim normalen Ende eines Thread
    28. ' die übergebene Liste senden
    29. Public Sub send(ByVal requests As List(Of String))
    30. workItems.Clear()
    31. runningThreads.Clear()
    32. ' copy string to work list
    33. workItems.AddRange(requests.ToArray)
    34. startThreads()
    35. End Sub
    37. ' stop alle laufenden Threads
    38. Public Sub [Stop]()
    39. SyncLock runningThreads
    40. workItems.Clear()
    41. For Each t As Thread In runningThreads
    42. If (t IsNot Nothing AndAlso t.IsAlive) Then t.Abort()
    43. Next
    44. runningThreads.Clear()
    45. End SyncLock
    46. End Sub
    48. ' startet weitere Threads wenn noch strings vorliegen
    49. Private Sub startThreads()
    50. ' start new threads
    51. While runningThreads.Count < maxThreadCount AndAlso workItems.Count > 0
    52. ' neues item aus der Liste nehmen und austragen
    53. Dim item As String = workItems(0)
    54. workItems.Remove(item)
    55. ' thread mit workitem starten und als laufend eintragen
    56. Dim _t As Thread = New Thread(New ParameterizedThreadStart(AddressOf doWork))
    57. _t.IsBackground = True
    58. runningThreads.Add(_t)
    59. _t.Start(item)
    60. End While
    62. End Sub
    64. ' Verarbeitungs Thread
    65. Private Sub doWork(ByVal o As Object)
    66. Dim sendString As String = o.ToString
    67. Debug.Print("thread started: " & sendString)
    68. Dim result As Boolean
    69. Try
    70. ' hier sollte die Verarbeitung erfolgen ..... result is true or false
    71. Thread.Sleep(500) ' test only
    72. Catch ex As ThreadAbortException
    73. Debug.Print("thread aborted: " & sendString)
    74. End Try
    75. ' thread has completed successful/failed
    76. RaiseEvent threadCompleted(Thread.CurrentThread, sendString, result)
    77. End Sub
    79. ' Event: wird aufgerufen wenn ein Thread normal endet (nicht bei Abort):
    80. Private Sub threadCompletedHandler(ByVal t As Thread, ByVal s As String, ByVal result As Boolean) Handles Me.threadCompleted
    81. Debug.Print("thread has ended: " & s)
    82. ' aus Liste laufender Threads austragen
    83. SyncLock runningThreads
    84. runningThreads.Remove(t)
    85. End SyncLock
    86. ' restart new threads
    87. If workItems.Count > 0 Then startThreads() : Return
    88. ' check finished
    89. If runningThreads.Count = 0 Then RaiseEvent SendCompleted()
    91. End Sub
    93. End Class



    Der Code macht folgendes:
    - speichern der laufenden Threads in einer Liste
    - an jedem Ende eines Threads wird ein lokaler Event ausgelöst, in dem dann ggf. neue Threads gestartet werden
    - wenn alle Strings (erfolgreich oder failed) verarbeitet wurden, wird ein Public Event SendCompleted ausgelöst

    Die Debug.Print Statements sollen nur helfen die Abfolge zu verstehen, genauso ist das Sleep Statement in dem Verarbeitungsthread nur für den Test vorhanden.

    Kommentier ruhig einmal die Synclocks aus um zu verstehen was dann passieren kann.

    Bei Fragen melde Dich wieder ...

    P.S: auch wenn es bestimmt nett gemeint war, ich denke 1x Bedanken pro Thread bei der gleichen person reicht locker aus

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

    Ich nochmal, ist zwar schon etwas her, aber naja..
    Also dein Beispiel klappt an sich eigentlich ziemlich gut und ist auch genau das was ich gebraucht habe, jedoch funktioniert es leider nicht richtig mit der API..
    Das Problem ist, dass wenn ich z.B. 5 Threads gleichzeitig starte, dann wird die Login-Funktion aufgerufen, wenn der Login geklappt hat, werden einige weitere Funktionen aufgerufen, z.B. um ein Video hochzuladen oder sonst was..das Problem ist nun, dass nun alle 5 Threads auf die gleiche Variable in der Funktion zugreifen, zur Verdeutlichung:

    VB.NET-Quellcode

    1. 'Variablen
    2. Public YouTubeRequestSettings As YouTubeRequestSettings
    3. Public YouTubeRequest As YouTubeRequest
    4. Public YouTubeVideo As Video
    6. 'Login-Funktion (teilweise abgekürzt):
    7. Public Function Login(username As String, password As String) As Boolean
    8. Try
    9. YouTubeRequestSettings = New YouTubeRequestSettings(username, password)
    10. YouTubeRequest = New YouTubeRequest(YouTubeRequestSettings)
    11. YouTubeVideo = YouTubeRequest.Retrieve(Of Video)
    12. Debug.Print(String.Format("Login mit Account '{0}' erfolgreich.", username))
    13. Catch ex As Exception
    14. Debug.Print(String.Format("Login mit Account '{0}' fehlgeschlagen.", username))
    15. Return False
    16. End Try
    17. Return True
    18. End Function
    20. 'Andere Funktion:
    21. Public Function MachWas(username As String) As Boolean
    22. Try
    23. YouTubeVideo.MachWas(...) 'hier wird also auf die Variable YouTubeVideo zugegriffen, welches auch Daten von den RequestSettings enthält (somit auch username & password)
    24. Debug.Print(String.Format("Funktion mit Account '{0}' erfolgreich.", username))
    25. Catch ex As Exception
    26. Debug.Print(String.Format("Funktion mit Account '{0}' fehlgeschlagen.", username))
    27. Return False
    28. End Try
    29. Return True
    30. End Sub
    32. 'Aufrufen (mit deiner (Kangaroo) Methode (in DoWork)):
    33. ...
    34. If Login(username, password) Then
    35. MachWas(username)
    36. End If
    37. ...

    Das Problem ist nun, dass z.B. Thread 1 einen erfolgreichen Login hatte und somit nun MachWas aufruft, aber in der Zwischenzeit schon Thread 2 versucht hat sich mit den anderen Account einzuloggen und hat somit die RequestSettings-Variablen verändert, welche jedoch aber in der Funktion MachWas von Thread 1 benutzt werden. Somit wird entweder mit einem falschen Account etwas gemacht, oder gar mit einem ungültigen Account, was dann zu einer Fehlermeldung führt..

    Hoffe du verstehst was mein Problem ist..

Facebook