У меня есть приложение .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;
}
}





В данном случае не очень много, так как они оба используют катушку с резьбой под капотом. Я бы сказал, что QueueUserWorkItem () легче читать и видеть, что происходит, по сравнению с BeginInvoke.
Эта ссылка может помочь. Это более старая информация, но в основном применима http://www.yoda.arachsys.com/csharp/threads/threadpool.shtml
Буквальный ответ на вопрос заключается в том, что оба используют пул потоков, поэтому разница невелика, если производительность является единственным соображением.
Если вопрос действительно в том, чтобы добиться максимальной производительности, может быть полезно знать, что при использовании пула потоков действительно есть проблемы. Они включают:
Возможно, стоит изучить 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];
});
Какие части не применимы?