前幾天折騰并行運算。在wanghui0380等大神的幫助下。折騰的差不多了。但是后來發現用task來多執行緒并行處理一些東西后。如果一段時間沒有呼叫(幾秒-數十秒左右)這個task方法后再次呼叫實行速度會慢很多。。。連續執行則沒有這個問題。觀察發現是并行處理的Task的執行緒啟動/自動退出導致的。
本想通過執行緒池來嘗試能否解決。但是由于現在程式結構都是用task來做的。所以想在改動程式較少的情況下。task能否完成類似的功能?使得一些執行緒得以保留?
原始代碼大概如下:
public static Task TestTask(int Index)
{
Task task1 = Task.Run(() =>
{
//較高耗時程序。。
return;
});
return task1;
}
Parallel.For(0, 6, new ParallelOptions() { MaxDegreeOfParallelism = 6 }, async (i) =>
{
await TestTask(i);
});
Console.WriteLine($"結束");
另外一個問題 Console.WriteLine($"結束"); 總是被提早執行了。沒有等到Parallel.For處理完成。 如上用 async (i) 也是如此?請問應該如何解決?
uj5u.com熱心網友回復:
沒看明白,已經使用Parallel了,怎么還需要Task。。
public static voidTestTask(int Index)
{
//較高耗時程序。。
}
Parallel.For(0, 6, new ParallelOptions() { MaxDegreeOfParallelism = 6 }, (i) =>
{
TestTask(i);
});
Console.WriteLine($"結束");
uj5u.com熱心網友回復:
先解決你后一個問題ConcurrentBag<Task> bag = new ConcurrentBag<Task>(); //注意這里請使用執行緒安全類串列,因為你下面這個并行實際會是多執行緒的,如果使用list這種非執行緒安全的串列,會產生意外
Parallel.For(0, 6, new ParallelOptions() { MaxDegreeOfParallelism = 6 }, (i) =>
{
bag.add(TestTask(i));
});
await Task.WhenAll(bag)
uj5u.com熱心網友回復:
看這個就很直觀了,肯定底部有執行緒池。
uj5u.com熱心網友回復:
至于你第1個問題,其實我們無法解決。因為你還是陷入到一個誤區,你認為執行緒就是立刻執行,非常執著的追求著“并行處理的Task的執行緒啟動/自動退出導致的。”
其實壓根就不是,我們前貼已經告訴你了,執行緒壓根就不存在什么立刻執行的說法。執行緒有自己的狀態:創建,就緒,執行中,掛起中,死亡
系統有執行緒調度器去調度執行緒,所以并沒有你說的什么啟動,自動退出如何如何導致你慢
所以這問題我無法繼續說明什么,只能直接給你下結論
1.task本身就是執行緒池,所以你無需糾結什么執行緒池問題。他解決了創建問題,也就是他會從池里就近去挑一個死亡狀態的執行緒給你,然后設定為就緒狀態,也就是與你自己創建執行緒相比,執行緒池的目的就是“約束創建的數量,節省掉創建程序,直接管理就緒,執行,掛起,死亡“
2.無論task也好,執行緒也罷,都歸執行緒調度器調度,執行緒調度器有幾個策略
public enum TaskCreationOptions
{
None = 0,
PreferFairness = 1,
LongRunning = 2,
AttachedToParent = 4,
DenyChildAttach = 8,
HideScheduler = 16
}
這塊你自己看(當然傳統執行緒還有優先級,只是在task體系里,這些優先級被上面那個列舉默認實作,比如longruning的優先級是低優先級)
3.不要糾結與執行緒不執行緒,你需要總體看當前“并行執行緒”,而不是糾結什么執行緒死啊,生啊。
如果系統當前并行執行緒1w個,你現在新加的執行緒是第1w零1個,你覺著現在調度器進行時間片切換調度的時候(我們就打你有8核,你可以同時運行8核執行緒)有多大幾率會在你就緒瞬間,就被調度到這個8個核的其中之一上了,很明顯,你并行執行緒越多,他立刻運行的幾率越小
所以我們前面也說了,請在保證業務的基礎上控制并發數量,同時請盡量減少單個執行緒的執行時間(做成小任務)
很明顯:如果前面1w都是小任務,很快走掉,比如4個時間片周期走掉8000個,那么你就排位就2001,你就有更大幾率被立刻執行
很明顯:如果我還控制了并發數量,那么后續加進來的執行緒會更少,我現在這個也會有更大幾率立刻執行
uj5u.com熱心網友回復:
同樣從池上的使用來說,也會要求你盡量拆成小任務,控制并發數量池本身有數量,所以如果你無限創建大任務,結果就是執行緒池滿。(要么例外,要么等待)
如果是等待池有釋放,當然他會慢
所以還是拿3句話,自己處理。別和博客園那些人一樣非名詞不會寫代碼。我們不要名詞,無論是執行緒也好,還是執行緒池也好,還是其他的技術
無論你用什么名詞寫代碼,就3條
1.有IO的及時清理記憶體
2.要計算的,盡量拆成小任務
3.在不影響設計要求的前提下,約束執行數量
uj5u.com熱心網友回復:
我們來看,task策略的其中一個PreferFairness:提示TaskScheduler以一種盡可能公平的方式安排任務,這意味著較早安排的任務將更可能較早運行,而較晚安排運行的任務將更可能較晚運行。
盡量公平--------------------------只是盡量公平,不是絕對公平
這意味著較早安排的任務將更可能較早運行---------------------較早有更大可能被提前調度,只是可能,盡可能被提前調度
而較晚安排運行的任務將更可能較晚運行。--------------------------一樣的口吻,他大概率會被延后調度,但是只是說大概率延后
uj5u.com熱心網友回復:
Task 是執行緒池的再包裝,請不要去雞蛋里面挑骨頭async / await 結構是異步回呼代碼的同步寫法 ,是語法糖
轉載請註明出處,本文鏈接:https://www.uj5u.com/net/280121.html
標籤:C#
