Обработка записей параллельно в .NET 2.0 с использованием нескольких потоков

Question

Мне нужно обрабатывать записи, доступные в таблице, параллельно, используя многопоточность. Я использую C# и настраиваю .NET 2.0.

Я знаю, что могу использовать Parallel.ForEach в .NET 4.0 для этого, но я не уверен, как его достичь с помощью .NET 2.0.

Answer 1

Без каких-либо других требований, многопоточность может быть реализована путем определения функции

static void Function() 
{ 
    // do some work here 
} 

, который затем используется в качестве точки входа для другого потока с помощью

Thread iThread = new Thread(Function); 

и

iThread.Start(); 

- это неблокирующий вызов, начинающийся с другого потока.

Answer 2

Вам необходимо зарегистрироваться Parallel.Foreach с помощью ThreadPool и ManualResetEvent.

public class Parallel 
{ 
    public static void ForEach<T>(IEnumerable<T> items, Action<T> action) 
    { 
     var resetEvents = new List<ManualResetEvent>(); 

     foreach (var item in items) 
     { 
      var evt = new ManualResetEvent(false); 
      ThreadPool.QueueUserWorkItem((i) => 
      { 
       action((T)i); 
       evt.Set(); 
      }, item); 
      resetEvents.Add(evt); 
     } 

     foreach (var re in resetEvents) 
      re.WaitOne(); 
    } 
} 

Вот example

Answer 3

До .Net 4.0 рекомендуемый способ для достижения параллельности является «ThreadPool», если у вас есть специальный случай использования.

Например, если вам нужен поток «Foreground Thread» или STA, вы напрямую используете класс Thread. В противном случае всегда отвечает ThreadPool.

Вы потребляете ThreadPool путем вызова метода ThreadPool.QueueUserWorkItem.

Однако QueueUserWorkItem не дает возможности дождаться завершения. Если вы хотите дождаться завершения, вы можете использовать Delegate.BeginInvoke, который возвращает IAsyncResult (приблизительный эквивалент задачи перед .Net 4.0), что позволяет подождать завершения и многое другое.

Answer 4

Вот пример моего answer to an earlier question, в котором показано, как запускать потоки и управлять тем, сколько из них выполняется за один раз. Это должно дать вам основу для начала.