C# - Как создать определенные части потоков пакетов из массива потоков

Question

У меня есть список с несколькими элементами. Я ищу простой способ запускать каждый раз определенное количество потоков. Как я могу контролировать, закончилась ли моя цепочка потоков, и я должен начать следующий пакет.

foreach (ListViewItem item in listViewEx1.CheckedItems) 
{          
    vList.Add((V)item.Tag); 

    Thread tr = new Thread(new ParameterizedThreadStart(Deploy)); 
    threads.Add(tr); 
    tr.Start((object)item.Tag); 
} 

Благодаря

Answer 1

Вы можете использовать Semaphore для обратного отсчета количества бегущих потоков и освобождения потоков от семафора.

То есть, я бы для другой установки:

• пут этот вид управления потоками в отдельном классе (не привязан к UI)

• Оставьте создание потоков на время выполнения с помощью библиотеки Task Parallel Library, создать Tasks и оставить пакетирование на время выполнения (отнимает много коды управления и чешую к аппаратным средствам.

Answer 2

Почему бы не использовать BackgroundWorker?

using System.ComponentModel; 
using System.Windows; 
using System.Windows.Controls; 

BackgroundWorker bw = new BackgroundWorker(); 
bw.WorkerReportsProgress = true; 
bw.WorkerSupportsCancellation = true; 
bw.DoWork += new DoWorkEventHandler(bw_DoWork); 
bw.ProgressChanged += new ProgressChangedEventHandler(bw_ProgressChanged); 
bw.RunWorkerCompleted += new RunWorkerCompletedEventHandler(bw_RunWorkerCompleted); 

if (bw.IsBusy != true) 
{ 
    bw.RunWorkerAsync(); 
} 
if (bw.WorkerSupportsCancellation == true) 
{ 
    bw.CancelAsync(); 
} 
private void bw_DoWork(object sender, DoWorkEventArgs e) { } 
private void bw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) { } 
private void bw_ProgressChanged(object sender, ProgressChangedEventArgs e) { } 

Когда bw_RunWorkerCompleted событие вызывается, то вы знаете, что ваш поток закончился.

Answer 3

Если вы используете .NET Framework 4.0, вы можете использовать параллельный LINQ:

// First, fill the vList-collection. 
vList.AddRange(listView1.CheckedItems.Cast<ListViewItem>().Select(item => (V)item.Tag)); 
// Second, for each item, call Deploy, but do this parallel. 
listView1.CheckedItems.Cast<ListViewItem>().AsParallel().ForAll(item => Deploy(item.Tag)); 

(Поскольку у меня не было весь код (как Deploy и vList) Я не уверен, если он будет компилировать, но это это только направление.)