Проблемы с Threading в vb.net

Question

Фон: У меня есть программа, которая обрабатывает множество записей в базе данных и создает задачи для выполнения. (В этом случае создание учетных записей пользователей в AD). Часть этого заключается в создании пользовательских каталогов, профилей и домашних каталогов и установке разрешений на них. Необходимо подождать, пока учетная запись объявления не будет реплицирована во всех наших DC.

Итак, у моей программы будет отдельный поток, ответственный за создание каталогов, которые будут обрабатывать очередь, заполненную из основного потока.

Я сделал некоторые исследования по Threading и придумать следующий шаблон кода:

Imports System.Threading 

Public Class Form1 
Dim worker As Object 
Private Sub Form1_Load(sender As Object, e As EventArgs) Handles MyBase.Load 
    worker = New workerObj(AddressOf resultcallback) 
    Dim t As New Thread(AddressOf worker.mainloop) 
End Sub 

Public Sub resultcallback(ByVal item As String) 
    Outbox.AppendText(item) 
End Sub 

Private Sub Button1_Click(sender As Object, e As EventArgs) Handles Button1.Click 
    worker.addItem(inbox.Text) 
End Sub 
End Class 

Public Delegate Sub resultcallback(ByVal item As String) 

Public Class workerObj 
Private myQueue As New Queue(Of String) 
Private myCallback As resultcallback 
Dim item As String = "nout" 

Public Sub New(ByVal callbackdelegate As resultcallback) 
    myCallback = callbackdelegate 
End Sub 

Public Sub mainloop() 
    While True 
     If myQueue.Count > 0 Then 
      item = myQueue.Dequeue() 
      myCallBack(item) 
     End If 
     Thread.Sleep(5000) 
    End While 
End Sub 

Public Sub addItem(ByVal item As String) 
    myQueue.Enqueue(item) 
End Sub 
End Class 

Проблема: На линии Dim т как новую нить .....

Error 1 Overload resolution failed because no accessible 'New' is most specific for these arguments: 
'Public Sub New(start As System.Threading.ParameterizedThreadStart)': Not most specific. 
'Public Sub New(start As System.Threading.ThreadStart)': Not most specific. n:\visual studio 2013\Projects\ThreadTest\ThreadTest\Form1.vb 7 13 ThreadTest 

Может ли кто-нибудь помочь мне сказать, где я ошибся? Cheers.

Answer 1

Темы не имеют общего конструктора, вам нужно вызвать Thread.Start. Я бы предложил, чтобы вы этого не делали. Написание потокобезопасного кода достаточно сложно, когда вы знаете о многопоточном программировании.

Например, в вашем коде вы изменяете очередь из двух разных потоков без блокировки. Очередь не является потокобезопасной, и вы можете повредить очередь. Вы должны заблокировать доступ к нему или использовать ConcurrentQueue, который равен поточно-безопасный. Другая ошибка заключается в попытке изменить TextBox из другого потока - это приведет к исключению, потому что только пользовательский интерфейс разрешает изменять элементы пользовательского интерфейса.

Лучшим вариантом является использование класса ActionBlock из библиотеки DataFlow, которая уже выполняет то, что вы хотите: запросы очереди и обрабатываете их в одном или нескольких отдельных потоках.

Ваш код может быть столь же простым, как это:

Dim myFileWorker=New ActionBlock(Of string)(Function(path) =>DoSomething(path)) 

For Each somePath As String in ListWithManyPaths 
    myFileWorker.Post(somePath) 
Next somePath 

myFileWorker.Complete() 
myFileWorker.Completion.Wait() 

По умолчанию один путь будет обрабатываться только на время. Чтобы обработать несколько путей вы передаете ExecutionDataflowBlockOptions объект с требуемым MaxDegreeOfParallelism:

Dim options=New ExecutionDataflowBlockOptions() With { .MaxDegreeOfParallelism=5} 
Dim myFileWorker=New ActionBlock(Of String) Function(path) DoSomething(path),options)