===前情提要=== 目前在重整资料库的资料(约2,800万笔)，所以必须一笔一笔爬 资料爬出来後会做两种处理，再建立新的资料库 资料库使用mongodb，先把整个collection做findall，再丢入foreach的回圈去跑 用了两个foreach，为省略版面，以下code只写一个foreach作为范本 ===方案A，单执行绪=== var result = coll.FindAll(); foreach(var doc in result) { 工作!(); } 结果： 工作A处理效能：20笔/秒 工作B处理效能：10笔/秒 慢慢做记忆体跟CPU都不炸 ===方案B，多执行绪=== var result = coll.FindAll(); foreach(var doc in result) { Task Task_CheckData = Task.Factory.StartNew(() => { 工作!(); }); } 结果： 工作A处理效能：900up笔/秒，持续加速 工作B处理效能：15up笔/秒，缓慢加速，资料库效能都被工作A吃掉了 炉~心~超~载~啦~ 由於一直生出新的Task，但程式又没有适当的释放资源，导致记忆体持续上升 吃完所有实体记忆体後执行速度很缓慢，而且也没有释放记忆体的情况 ===方案C，多执行绪+Dispose=== var result = coll.FindAll(); foreach(var doc in result) { Task Task_CheckData = Task.Factory.StartNew(() => { 工作!(); }); Task_CheckData.Wait(); Task_CheckData.Dispose(); } 结果： 工作A处理效能：20笔/秒 工作B处理效能：10笔/秒 体悟心灵祥和ˊㄇˋ 已经变成单执行绪的形状了 ===方案D，多执行绪+ContinueWith，失败=== var result = coll.FindAll(); foreach(var doc in result) { Task Task_CheckData = Task.Factory.StartNew(() => { 工作!(); }); Task_CheckData.ContinueWith(antecendent => { Task_CheckData_Each.Dispose(); }, TaskScheduler.FromCurrentSynchronizationContext()); } 结果： 程式整个卡住不跑... D方案比C方案早生出来 因为失败了所以先前没key ===问题结论=== 大概出在Task的使用上 但喂狗後还是没发现比较好的解决方案 或许是我关键字下错QQ 请版上先知指教，谢谢 --

※ 发信站: 批踢踢实业坊(ptt.cc), 来自: 111.82.219.136 ※ 文章网址: https://webptt.com/cn.aspx?n=bbs/C_Sharp/M.1468566664.A.390.html 补充方案D，感谢各位 将回圈改为Parallel.ForEach 工作A处理效能：500up笔/秒，缓慢增加 工作B处理效能：230up笔/秒，缓慢增加 记忆体有增长，但是成长的量不大，且有明显回收记忆体的现象，持续观察~ 非常感谢！ 的确是..之後会试着把Task在回圈外宣告 然後回圈内加入新工作 感恩！ 切chunk的方式我有想过，但是资料库资料蛮不连续的 可能需要用第A笔至第B笔来切 速度的部分，目前是连线去呼叫资料库，查询时间略久，每做一次查询回传约1xx毫秒 一个工作内会做1~4次查询 感谢你的建议与问题~~ ※ 编辑: moumou17 (111.82.219.136), 07/15/2016 16:06:00