Ich habe mal schnell ein Bespiel geschrieben welches mit 2 Threads arbeitet. Der Erste Thread überwacht ein Verzeichnis und bei Änderungen speichert er diese in die Auflistung (Queue). Der zweite Thread prüft ständig ob es Einträge in der Auflistung gibt,
wenn ja nimmt er dieses Object aus der Auflistung heraus und zeigt es in einer Listbox an.
Die ist wie gesagt ein ganz einfaches Beispiel, welches nur zeigen soll wie es ungefähr gehen könnte, da ich nicht weiß wie Deine Daten ankommen. Mann sollte es auch noch threadsicher machen siehe
Queue
Gruß Thomas
Public Class Form1
'
Private Structure objTest
Public strEreignis As String
Public strFile As String
Public Overrides Function ToString() As String
Return strEreignis & ":" & strFile
End Function
End Structure
'
Private WithEvents bwReadThread As System.ComponentModel.BackgroundWorker
Private WithEvents bwSaveThread As System.ComponentModel.BackgroundWorker
Private lstQueue As System.Collections.Generic.Queue(Of objTest)
Private Sub Form1_FormClosing(sender As Object, e As System.Windows.Forms.FormClosingEventArgs) Handles Me.FormClosing
If IsNothing(bwReadThread) = False AndAlso bwReadThread.IsBusy = True Then
bwReadThread.CancelAsync
bwReadThread.Dispose
End If
If IsNothing(bwSaveThread) = False AndAlso bwSaveThread.IsBusy = True Then
bwSaveThread.CancelAsync
bwSaveThread.Dispose
End If
End Sub
'
Private Sub Form1_Load(sender As Object, e As System.EventArgs) Handles Me.Load
lstQueue = New System.Collections.Generic.Queue(Of objTest)
bwReadThread = New System.ComponentModel.BackgroundWorker
bwReadThread.WorkerSupportsCancellation = True
bwReadThread.RunWorkerAsync
'//
bwSaveThread = New System.ComponentModel.BackgroundWorker
bwSaveThread.WorkerSupportsCancellation = True
bwSaveThread.WorkerReportsProgress = True
bwSaveThread.RunWorkerAsync
'//
End Sub
'
#Region "Thread-1"
'
Private Sub AusleseThread_DoWork(sender As Object, e As System.ComponentModel.DoWorkEventArgs) Handles bwReadThread.DoWork
'//
Dim fw As New IO.FileSystemWatcher("C:\Users\[USER]\AppData\Local\Temp")
AddHandler fw.Changed, AddressOf ObjectChanged
AddHandler fw.Renamed, AddressOf ObjectRenamed
fw.EnableRaisingEvents = True
'//
Do While DirectCast(sender, System.ComponentModel.BackgroundWorker).CancellationPending = False
Loop
'//
fw.EnableRaisingEvents = False
'//
End Sub
'
Private Sub ObjectChanged(sender As Object, e As System.IO.FileSystemEventArgs)
Dim t As New objTest
t.strEreignis = "geändert"
t.strFile = e.Name
Me.lstQueue.Enqueue(t)
End Sub
'
Private Sub ObjectRenamed(sender As Object, e As System.IO.RenamedEventArgs)
Dim t As New objTest
t.strEreignis = "umbenannt"
t.strFile = e.Name
Me.lstQueue.Enqueue(t)
End Sub
'
#End Region
'
#Region "Thread-2"
'
Private Sub AnzeigeThread_DoWork(sender As Object, e As System.ComponentModel.DoWorkEventArgs) Handles bwSaveThread.DoWork
'//
Do While DirectCast(sender, System.ComponentModel.BackgroundWorker).CancellationPending = False
'//
If Me.lstQueue.Count > 0 Then
DirectCast(sender, System.ComponentModel.BackgroundWorker).ReportProgress(0, Me.lstQueue.Dequeue)
End If
'//
Loop
'//
End Sub
'
Private Sub AnzeigeThread_ProgressChanged(sender As Object, e As System.ComponentModel.ProgressChangedEventArgs) Handles bwSaveThread.ProgressChanged
If IsNothing(e.UserState) = False Then
Me.ListBox1.Items.Add(DirectCast(e.UserState, objTest).ToString)
End If
End Sub
'
#End Region
'
End Class
