对于循环与 c# 中的线程池
本文关键字:线程 于循环 循环 | 更新日期: 2023-09-27 18:30:51
我有一个场景,我需要以这种方式将记录的插入(插入)划分到表中,这样就不会那么慢,目前我有 81K 行记录要插入,前几天使用当前过程大约需要 4-5 小时才能完成。我想增强线程进程,或者只是将插入分成批,比如按 20 年代 (81,000/20),每次使用 for 循环处理 4k 行。哪一个是最好的推荐。
这是我当前的代码:
iProcs = 81000/20;
Thread[] threads = new Thread[iProcs]
for (int i = 0; i < iProcs; i++)
{
//range of values to get
iStart = iRange * i;
if (i == iProcs - 1) //for last processor use the rest of the list
iEnd = packageList.Count - iStart;
else
iEnd = iRange;
var listSubset = packageList.GetRange(iStart, iEnd).ToList();
Thread myThread = new Thread(
delegate()
{
service.PostToClient(listSubset);
}
);
myThread.Start();
threads[i] = myThread;
}
// all threads should complete before we continue with main.
foreach (Thread thread in threads) { thread.Join(); }
上面的代码很慢,如果这更有效,我还没有在下面测试这个:
for (int i = 0; i <= iProcs; i++)
{
iStart = i * iRange;
// lets add what's been processed
iEnd = iRange;
// find out how much record is left to process
int cntleft = totalRec - iStart;
if (cntleft < iEnd)
iEnd = cntleft;
// process data save images to db
var listSubset = packageList.GetRange(iStart, iEnd).ToList();
// service.PostToDB(listSubset);
}
我没有做过太多的线程程序,所以我不是真正的专家,甚至不是平庸的。
任何回应都值得赞赏。 谢谢。
- 如果可能的话,首先使用SqlBulkCopy(用于sql服务器)或其他BulkCopy(取决于数据库供应商)
- 如果您需要尽快插入数据,请在实际硬件上使用多个插入线程执行一些基准测试。通过此数据,您可以优化插入线程的数量以获得最佳时间。