如何等待，直到線程池中的所有工作線程都消失

Question

任何人都知道這麼做的簡單方法？

基本上，我排隊所有的作品後，我想等待，直到我所有排隊完成。我該怎麼做？

loopThroughAllBlog(whattodo, login)'queue all works 

//在這裏做什麼等待所有排隊的作品完成。

Dim whatToWrite = New Generic.List(Of String) 
    For Each domain In domainsSorted 
     whatToWrite.Add(dictionaryOfOutput.Item(domain)) 
    Next 
    coltofile(whatToWrite, "output.txt", True) 

我注意到沒有辦法知道有多少線程仍在線程池中運行。

Answer 1

我最終回答了我自己的問題，因爲沒有答案。

Public Function threadPoolIdle() As Boolean 
    Dim workerThreads As Integer 
    Dim completionPorts As Integer 
    Dim maxWorkerThreads As Integer 
    Dim maxCompletionPorts As Integer 
    Dim stillWorking As Integer 

    Threading.ThreadPool.GetAvailableThreads(workerThreads, completionPorts) 
    Threading.ThreadPool.GetMaxThreads(maxWorkerThreads, maxCompletionPorts) 
    stillWorking = maxWorkerThreads + maxCompletionPorts - workerThreads - completionPorts 

    If stillWorking > 0 Then 
     Return False 
    Else 
     Return True 
    End If 

End Function 

Public Sub waitTillThreadPoolisIdle() 
    Do 
     Sleep(1000) 
     Application.DoEvents() 
    Loop While threadPoolIdle() = False 
End Sub 

我認爲這只是尷尬。一定有更好的方法。

Answer 2

實現此目的的常用方法是使用受信號量保護的計數器。 （在我看來，你的代碼是VB，我不知道VB，所以我的語法可能是關閉的，把它當作僞代碼）。

首先，你需要設置信號燈和計數器：

' a semaphore is a counter, you decrease it with WaitOne() and increase with Release() 
' if the value is 0, the thread is blocked until someone calls Release() 
Dim lock = new Semaphore(0, 1) 
Dim threadcount = 10 ' or whatever 

在函數的末尾由線程池運行，你需要減少線程計數器，並釋放鎖如果THREADCOUNT在0

threadcount = threadcount - 1 
if threadcount = 0 then 
    lock.Release() 
end if 

等待你的線程時，嘗試將收購的信號，這將阻塞，直到有人叫釋：

lock.WaitOne() 

對於上面的減少和檢查操作，你可能想要把它放在一個單獨的子程序中。您還需要保護它，以便每個嘗試訪問計數器的線程都與其他線程隔離。

dim counterMutex = new Mutex() 
sub decreaseThreadCount() 
    counterMutex.WaitOne() 
    threadcount = threadcount - 1 
    if threadcount = 0 then 
     lock.Release() 
    end if 
    counterMutex.release() 
end sub