Ограничьте количество параллельных потоков в C #

Я пишу программу на C # для создания и загрузки полумиллиона файлов через FTP. Я хочу обрабатывать 4 файла параллельно, так как машина имеет 4 ядра, а создание файла занимает гораздо больше времени. Можно ли преобразовать следующий пример Powershell в C #? Или есть какая-нибудь лучшая структура, такая как Actor framework в C # (например, F # MailboxProcessor)?

Пример Powershell

$maxConcurrentJobs = 3;

# Read the input and queue it up
$jobInput = get-content .\input.txt
$queue = [System.Collections.Queue]::Synchronized( (New-Object System.Collections.Queue) )
foreach($item in $jobInput)
{
    $queue.Enqueue($item)
}

# Function that pops input off the queue and starts a job with it
function RunJobFromQueue
{
    if( $queue.Count -gt 0)
    {
        $j = Start-Job -ScriptBlock {param($x); Get-WinEvent -LogName $x} -ArgumentList $queue.Dequeue()
        Register-ObjectEvent -InputObject $j -EventName StateChanged -Action { RunJobFromQueue; Unregister-Event $eventsubscriber.SourceIdentifier; Remove-Job $eventsubscriber.SourceIdentifier } | Out-Null
    }
}

# Start up to the max number of concurrent jobs
# Each job will take care of running the rest
for( $i = 0; $i -lt $maxConcurrentJobs; $i++ )
{
    RunJobFromQueue
}

Обновление:
Подключение к удаленному FTP-серверу может быть медленным, поэтому я хочу ограничить обработку загрузки по FTP.

22
задан ca9163d9 13 May 2015 в 14:26
поделиться