对于循环与 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);

                }

我没有做过太多的线程程序,所以我不是真正的专家,甚至不是平庸的。

任何回应都值得赞赏。 谢谢。

对于循环与 c# 中的线程池

  1. 如果可能的话,首先使用SqlBulkCopy(用于sql服务器)或其他BulkCopy(取决于数据库供应商)
  2. 如果您需要尽快插入数据,请在实际硬件上使用多个插入线程执行一些基准测试。通过此数据,您可以优化插入线程的数量以获得最佳时间。