Использовать асинхронные делегаты или ThreadPool.QueueUserWorkItem для массового параллелизма? - PullRequest
Новая
       39

Использовать асинхронные делегаты или ThreadPool.QueueUserWorkItem для массового параллелизма?

6 голосов
/ 10 октября 2008

У меня есть приложение .NET, которое обрабатывает около 300 000 записей в пакетном импорте, и на каждую запись уходит несколько секунд, поэтому я бы хотел распараллелить это. В следующем коде, в чем разница между ProcessWithAnsycDelegates() и ProcessWithThreadPool()? 

public class ResultNotification
 { public EventHandler event Success;
   public EventHandler event Fail;
   internal void Notify(bool sucess) {if (success) Success(); else Fail();}
 }

public static class Processor
 { public ResultNotification ProcessWithAnsycDelegates(Record record)
    { var r = new ResultNotification();
      Func<Record,bool> processRecord=new RecordProcessor().ProcessRecord;
      processRecord.BeginInvoke
                     ( record
                      ,ar => result.Notify(processRecord.EndInvoke(ar))
                      ,null); 
      return r;    
    }

   public ResultNotification ProcessWithThreadPool(Record r)
    { var r  = new ResultNotification();
      var rp = new RecordProcessor();
      ThreadPool.QueueWorkUserItem(_=>result.Notify(rp.ProcessRecord(r)));
      return r;
    }
 }

Ответы [ 2 ]

7 голосов
/ 12 октября 2008

Дословный ответ на вопрос заключается в том, что оба используют пул потоков, поэтому разница не так велика, если производительность является единственным фактором.

Если вопрос действительно в том, чтобы добиться максимальной производительности, то это может помочь узнать, что использование пула потоков действительно имеет проблемы. К ним относятся:

  • Блокировка конкуренции в рабочей очереди
  • Чрезмерное переключение контекста. Если у вас 2 ЦП и последовательность рабочих элементов, тогда 25 потоков не помогут. Лучше иметь 2 потока, по одному на каждый процессор

Возможно, стоит изучить TPL и PLINQ:

Один пример использования TPL, который они приводят: 

for (int i = 0; i < 100; i++) { 
  a[i] = a[i]*a[i]; 
}

до: 

Parallel.For(0, 100, delegate(int i) { 
  a[i] = a[i]*a[i]; 
});
6 голосов
/ 10 октября 2008

В этом случае не так много, так как они оба используют пул под капотом. Я бы сказал, что QueueUserWorkItem () легче читать и видеть, что происходит по сравнению с BeginInvoke.

Эта ссылка может помочь. Это старая информация, но все еще в основном применима http://www.yoda.arachsys.com/csharp/threads/threadpool.shtml

...