本文為原創(chuàng)文章蛀蜜,轉載請注明出處,謝謝你……
> 喜歡java并發(fā)編程的請加群:736156823
開始-->
有些時候增蹭,我們想使用非阻塞隊列,但是還希望如果隊列中有任務到來時就去即時的消費掉壮池。
這里的即時消費是帶有時間忍受度的,也就是說杀怠,當任務到達隊列中時希望最多在非阻塞隊列中停留最多3毫秒(或者300毫秒,3納秒橙依,自定義)就要被消費掉,那么改怎么使用呢窗骑?
代碼示例如下(這時原來線上的代碼):
最近幾天運維和我說機器cpu使用率經常90%不掉(單核使用率),今天把代碼修改后如下:
本地1000個線程同時掛在到concurrentqueue创译,一個生產者for循環(huán)放入墙基,每放入一個休眠1微妙,cpu占用10%左右残制,測試通過。
至于里面的一些參數(shù)是什么初茶,請自己猜測吧,還有至于測試的demo怎么寫也請自己完成吧恼布,都很簡單的,就這樣折汞。
后面會給出代碼靈感,與相關分析內容凤藏。
> 喜歡java并發(fā)編程的請加群:736156823
結束-->
本文為原創(chuàng)文章堕伪,轉載請注明出處揖庄,謝謝你……