Module mThreading
    ''' <summary>
    ''' Klasse zum Kpseln diverser Multithreading-Aufgaben
    ''' Erstellt von Jörg Schützner im August 2010
    ''' </summary>
    ''' <typeparam name="T"></typeparam>
    ''' <remarks></remarks>
    Public MustInherit Class MultiTaskProcessor(Of T)
        Inherits ThreadWrapperBase
 
        Public Event Completed As EventHandler(Of MTP_ThreadEventArgs)
        Public Event Paused As EventHandler(Of MTP_ThreadEventArgs)
        Public Event Continued As EventHandler(Of MTP_ThreadEventArgs)
        Public Event Abborted As EventHandler(Of MTP_ThreadEventArgs)
        Public Event AbbortRequested As EventHandler(Of MTP_ThreadEventArgs)
        Public Event Started As EventHandler(Of MTP_ThreadEventArgs)
 
        Public Event SingleTaskCompleted As EventHandler(Of MTP_ThreadEventArgs)
        Public Event SingleTaskStarted As EventHandler(Of MTP_ThreadEventArgs)
        Public Event SingleTaskAbborted As EventHandler(Of MTP_ThreadEventArgs)
 
        Protected MustOverride Sub DoWork(ByVal Obj As T)
 
        Protected mPauseWaitHandle As New System.Threading.ManualResetEvent( _
          True)
        Protected mInputListeWaitHandle As New _
        System.Threading.ManualResetEvent(True)
 
        Protected mPaused As Boolean = True
        Protected mListClose As Boolean
 
        'Listen...
        Protected mInputList As New Queue(Of T)
        Protected mOutputList As New Queue(Of T)
        Protected mErrorList As New Queue(Of T)
 
        Protected mWorkTime As TimeSpan = TimeSpan.Zero
        Protected mStartTick As Date
        Protected mUseOutputList As Boolean = False
        Protected mInputListWaitTimeout As Integer = 500
        Protected mOutputListWaitTimeout As Integer
        Protected mCPU_Count As Integer
        Protected mAnzTasks As Integer
        Protected mStartTimeout As Integer
        Protected mMaxTaskCount As Integer
        Protected mStartRequested As Boolean = False
        Protected mNoDoubleItems As Boolean 'Keine Doubletten in der Inputliste 
        ' zulassen
 
        Private mSingleThreads As New List(Of SingleTaskProcessor)
 
        'TODO: OutputListe integrieren
        'TODO: reine Rechenzeit ermitteln
        'TODO: Ermöglichen, das die Reihenfolge der Eingabe auch Reihenfolge 
        ' der Ausgabe ist, falls gewünscht
 
 
        Protected Sub OnEvent(ByVal Sender As Object, ByVal e As EventArgs, _
          ByVal [Event] As System.Delegate)
            Dim Fired As Boolean = False
            If [Event] IsNot Nothing Then
                For Each singlecast As System.Delegate In _
                  [Event].GetInvocationList
                    Fired = False
                    Try
                        Dim syncInvoke As _
                          System.ComponentModel.ISynchronizeInvoke = CType( _
                          singlecast.Target, _
                          System.ComponentModel.ISynchronizeInvoke)
                        If syncInvoke IsNot Nothing AndAlso _
                        syncInvoke.InvokeRequired Then
                            Fired = True
                            syncInvoke.Invoke(singlecast, New Object() {Sender, _
                              e})
                        Else
                            Fired = True
                            singlecast.DynamicInvoke(New Object() {Sender, e})
                        End If
                    Catch ex As System.Reflection.TargetInvocationException
                        If Not Fired Then
                            singlecast.DynamicInvoke(New Object() {Sender, e})
                        End If
                    End Try
                Next
            End If
        End Sub
 
'...... Hier komt dann der Rest........