0

我有一个每 10 秒运行一次的队列：

Private Sub Form1Load(ByVal sender As Object, ByVal e As EventArgs) Handles MyBase.Load

        Dim t As New Timers.Timer(10000)
        AddHandler t.Elapsed, New ElapsedEventHandler(AddressOf Elapsed)
        t.Start()
    End Sub

    Private Sub Elapsed(ByVal sender As Object, ByVal e As ElapsedEventArgs)

        Dim timer1 As Timers.Timer = DirectCast(sender, Timers.Timer)

        Try
            ' disable temporarily
            timer1.Stop()
            _quemanager.StartProcessing()
            Thread.Sleep(1000)
        Finally
            ' make sure that the handler is always reenables
            timer1.Start()
        End Try
    End Sub

Namespace Managers

    Public Class QueueManager

        Private ReadOnly _items As New Queue

        Public Sub StartProcessing()

            For Each x In From i In File.GetAllAccountFolders() From x1 In File.CheckFolderForFiles(i & "\In") Select x1
                _items.Enqueue(x)
            Next

            Dim t1 As New Threading.Thread(AddressOf Process)

            t1.Start()
        End Sub

        Private Sub Process()
            Do
                SyncLock _items.SyncRoot
                    If _items.Count = 0 Then
                        'No more items.
                        Logger.Log("QueueManager", "Process", "No Items In Queue")
                        Exit Do
                    End If
                    Logger.Log("QueueManager", "Process", "Processing File: " & _items.Peek)
                    FileProcessingManager.ProcessFile(_items.Peek)
                    _items.Dequeue()
                End SyncLock
            Loop
        End Sub

    End Class
End Namespace

这背后的逻辑应该是计时器每 10 秒经过一次停止计时器运行队列，然后当队列完成时，它应该再次启动计时器我是否有这种想法？并且在队列完成之前计时器无法重新启动它自己？

谢谢

4

1 回答 1

1

在您的示例代码中，QueueManager. StartProcessing启动一个新线程来处理队列中的项目。这意味着它将立即返回，可能在处理队列之前。然后，在 timer elapsed 事件处理程序中，在一秒延迟后重新启动计时器。因此，如果队列的处理时间超过一秒，那么计时器确实会在队列处理完成之前重新启用。在这种情况下，我会完全取消那一秒钟的睡眠，并在完成后QueueManager引发一个事件。然后您的表单可以只监视该事件，当它被引发时，它可以重新启用事件处理程序中的计时器。Me.Invoke不过，在触摸计时器的属性之前，您需要先返回 UI 线程。

Public Class Form1
    Private WithEvents _quemanager As New QueueManager()
    Private WithEvents _t As New Timers.Timer(10000)

    Private Sub Form1Load(ByVal sender As Object, ByVal e As EventArgs) Handles MyBase.Load
        t.Start()
    End Sub

    Private Sub _t_Elapsed(ByVal sender As Object, ByVal e As ElapsedEventArgs) Handles _t.Elapsed
        ' disable temporarily
        _t.Stop()
        _quemanager.StartProcessing()
    End Sub

    Private Sub _quemanager_ProcessingCompleted() Handles _quemanager.ProcessingCompleted
        _t.Start()
    End Sub
End Class

Public Class QueueManager
    Private ReadOnly _items As New Queue
    Public Event ProcessingCompleted()

    Public Sub StartProcessing()
        '...
    End Sub

    Private Sub Process()
        Do
            '...
        Loop
        RaiseEvent ProcessingCompleted()
    End Sub
End Class
于 2012-07-13T12:09:50.227 回答