標籤: 南投搬家費用

哈吉貝肆虐 福島輻射污染土吹入河川 但類案早已層出不窮

admin

文：宋瑞文

本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

加州政府大力扶持 電動車銷量衝破 10 萬

admin

美國加州電動車銷量突破 10 萬輛，在全美電動車交易中，加州占約 40 %。業界指出，銷量增加的主要原因是充電站數量遽增，加上電動車製造商引進更多車款，吸引更多消費者購買。   加州政府希望 2025 年前，電動車數目可達 150 萬輛。目前在美購買電動車的車主可申請聯邦退款 7500 美元，而加州的車主還可另外再獲退款 2500 美元，並享有使用高使用量車道的特權。

本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

.NET Core請求控制器Action方法正確匹配，但為何404？

admin

前言

有些時候我們會發現方法名稱都正確匹配，但就是找不到對應請求接口，所以本文我們來深入了解下何時會出現接口請求404的情況。

匹配控制器Action方法（404）

首先我們創建一個web api應用程序，我們給出如下示例控制器代碼

[ApiController]
[Route("[controller]/[action]")]
public class WeatherController : ControllerBase
{
    [HttpGet]
    string Get()
    {
        return "Hello World";
    }
}

 

當我們進行如上請求時會發現接口請求不到，這是為何呢？細心的你應該可能發現了，對於請求方法是私有，而不是公共的，當我們加上public就可以請求到了接口

[HttpGet("get")]
public string Get()
{
    return "Hello World";
}

匹配控制器Action方法本質

經過如上示例，那麼對於Action方法的到底要滿足怎樣的定義才能夠不至於請求不到呢？接下來我們看看源碼怎麼講。我們找到DefaultApplicationModelProvider類，在此類中有一個OnProvidersExecuting方法用來構建控制器和Action方法模型，當我們構建完畢所有滿足條件的控制器模型后，緊接着勢必會遍歷控制器模型去獲取對應控制器模型下的Action方法，這裏只截取獲取Action方法片段，源碼如下：

foreach (var controllerType in context.ControllerTypes)
{    
    //獲取控制器模型下的Action方法
    foreach (var methodInfo in controllerType.AsType().GetMethods())
    {
        var actionModel = CreateActionModel(controllerType, methodInfo);
        if (actionModel == null)
        {
            continue;
        }

        actionModel.Controller = controllerModel;
        controllerModel.Actions.Add(actionModel);    
    }
}

上述紅色標記則是創建Action模型的重點，我們繼續往下看到底滿足哪些條件才創建Action模型呢？

protected virtual ActionModel CreateActionModel(TypeInfo typeInfo, MethodInfo methodInfo)
{
    if (typeInfo == null)
    {
        throw new ArgumentNullException(nameof(typeInfo));
    }

    if (methodInfo == null)
    {
        throw new ArgumentNullException(nameof(methodInfo));
    }

    if (!IsAction(typeInfo, methodInfo))
    {
        return null;
    }    
    ......    
}

到了這個方法裏面，我們找到了如何確定一個方法為Action方法的源頭，由於該方法有點長，這裏我採用文字敘述來作為判斷邏輯，如下：

protected virtual bool IsAction(TypeInfo typeInfo, MethodInfo methodInfo)
{
    //如果有屬性訪問器（無效）

    //如果有NonAction特性標識無效）

    //如果重寫Equals(Object), GetHashCode()方法（無效）

    //如果實現Dispose方法（無效）

    //如果是靜態方法（無效）

    //如果是抽象方法（無效）

    //如果是構造函數（無效）

    //如果是泛型方法（無效）

    //必須為公共方法
    return methodInfo.IsPublic;
}

如上是從方法定義的角度來過濾而獲取Action方法，除此之外，我們請求方法的名稱還可以自定義，比如通過路由、ActionName特性指定，那麼這二者是否存在優先級呢？比如如下示例：

[ApiController]
[Route("[controller]/[action]")]
public class WeatherController : ControllerBase
{
    [HttpGet]
    [ActionName("get1")]
    public string get()
    {
        var routeValue = HttpContext.Request.RouteValues.FirstOrDefault();

        return routeValue.Value.ToString();
    }
}

我們可以看到此時將以ActionName特性作為方法名稱。所以在上述過濾方法定義后開始構建方法模型，在此之後還會再做一步操作，那就是查找該方法是否通過ActionName特性標識，若存在則以ActionName特性標識給定的名稱作為請求方法名稱，否則以方法定義名稱為準，源碼如下：

var actionModel = new ActionModel(methodInfo, attributes);

AddRange(actionModel.Filters, attributes.OfType<IFilterMetadata>());

var actionName = attributes.OfType<ActionNameAttribute>().FirstOrDefault();
if (actionName?.Name != null)
{
    actionModel.ActionName = actionName.Name;
}
else
{
    actionModel.ActionName = methodInfo.Name;
}

還沒完，若是將路由特性放到Action方法上，如下，此時請求接口應該是weather/get還是weather/get1呢？

[ApiController]
public class WeatherController : ControllerBase
{
    [HttpGet]
    [Route("weather/get")]
    [ActionName("get1")]
    public string get()
    {
        var routeValue = HttpContext.Request.RouteValues.FirstOrDefault();

        return routeValue.Value.ToString();
    }
}

此時若我們以weather/get1請求將出現404，還是以路由特性模板給定為準進行請求，但最終會將路由上Action方法名稱通過ActionName特性上的名稱賦值給Action模型中的ActionName進行覆蓋，源碼如下，所以上述我們得到的action名稱為get1，，當然這麼做沒有任何實際意義。

public static void AddRouteValues(ControllerActionDescriptor actionDescriptor,ControllerModel controller,ActionModel action)
{
    foreach (var kvp in action.RouteValues)
    {
        if (!actionDescriptor.RouteValues.ContainsKey(kvp.Key))
        {
            actionDescriptor.RouteValues.Add(kvp.Key, kvp.Value);
        }
    }

    if (!actionDescriptor.RouteValues.ContainsKey("action"))
    {
        actionDescriptor.RouteValues.Add("action", action.ActionName ?? string.Empty);
    }

    if (!actionDescriptor.RouteValues.ContainsKey("controller"))
    {
        actionDescriptor.RouteValues.Add("controller", controller.ControllerName);
    }
}

總結

本文我們只是單獨針對查找Action方法名稱匹配問題做了進一步的探討，根據源碼分析，對Action方法名稱指定會做3步操作：第一，根據方法定義進行過濾篩選，第二，若方法通過AcionName特性標識則以其所給名稱為準，否則以方法名稱為準，最終賦值給ActionModel上的ActionName屬性，第三，將ActionModel上的ActionName值賦值給路由集合中的鍵Action。

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※帶您來了解什麼是 USB CONNECTOR  ?

※自行創業缺乏曝光? 網頁設計幫您第一時間規劃公司的形象門面

※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!

※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化

※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益

※教你寫出一流的銷售文案?

中德合作綱要簽署 電動車受惠

admin

10月10日，中國國務院總理李克強在柏林同德國總理安格拉•默克爾共同主持第三輪中德政府磋商。雙方決定發表《中德合作行動綱要：共塑創新》(下文簡稱《綱要》)。《綱要》共包含86項條文，其中8項提及汽車工業，新能源汽車標準制定與應用推廣成為重中之重。   雙方同意，要繼續加大政府對電動汽車研發、市場開發、基礎設施建設等領域的扶持。雙方商定，給予企業平等享受電動汽車國家扶持和優惠的待遇，並在國家規章、標準制訂中加強協調。雙方將繼續深化中德在電動汽車領域的標準合作。雙方應在充電基建領域就擴建策略和經營模式等議題加強對話。   《綱要》提及，中德兩國應深化電動汽車示範專案和試點城市的交流與合作。在已建立的城市合作框架下，鼓勵中德其他具備條件的城市積極參與。雙方將在電動汽車戰略平臺框架下，探討共建充電基礎設施和電動汽車與智慧電網互通示範項目。它還提出由中國國家發展改革委和德國聯邦環境、自然保護、建築和核安全部牽頭，雙方將繼續深化在電動汽車電池回收利用領域的合作。

本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

小班同學學習經歷分享（一）遊戲程序員成長札記

admin

作者信息

昵稱：目及遠方

課程設計 HumanFramework：

https://github.com/cyclons/HumanFramewo

正文

大四畢業，心血來潮，閑余之際，撰文留念。

萌芽

遊戲程序員，把這個分成兩塊的話就是，遊戲，程序。

這兩个中，只有一個，遊戲，在我很小的時候就開始接觸，在那個視电子遊戲如电子海洛因，父母抵制到要送孩子去網癮治療所的年代，三年級的我就已經在玩ps2了，周圍的同學還在玩紅警qq大亂斗冒險島飛車的時候，我已經玩高達戰神龍珠古墓麗影，最終導致和周圍同學沒有共同話題。

隨後，按順序入手了nds，psp，xbox360，ps4，可以說從小到大，遊戲沒有停過。

如果說這條職業路上我有什麼超前之處，就是玩遊戲玩得多。

起步

那什麼時候開始想做遊戲了呢？要等到大學。

整個大一的我沉浸在社團幹事與學習中，完全沒有接觸過遊戲編程，學了個譚浩強的c語言，寒假里把下學期的高數學了一遍，然後發現課堂上除了能裝個逼好像也沒什麼特別大用。

直到下半學期的一天夜裡，我在床上思考，以後究竟干什麼比較好，突然一個念頭冒出來，要不去做遊戲吧！這個想法一冒出來，我猛地從床上坐了起來，彷彿一股能量貫穿了全身一般，於是我下定決心買一台電腦，開始我的程序之路。

暑假的時候，搜了好久，終於找到一個感覺靠譜的教程，那就是SIKI，現在已經是遊戲網課的巨頭了，然而當時僅僅只是一個維持了一個小小的公眾號而已，唯一收費的只有一個A計劃，終身費只要400塊。當時選擇的原因有很多，其中最主要的就是大量的免費課程，一個個案例都是自己想要實現的遊戲，總感覺每實現一個，就離成為遊戲製作人更近一步（當時沒有遊戲職業概念）。

成長

剛開始學的階段，可以說我就是個沙雕，半吊子中的半吊子，打字速度20字母/s，不懂語法，大小寫不分，對着視頻敲代碼。（彎路）

後來發現儘管照着視頻做出來了，但仍然不熟練，於是逼迫自己，看視頻不寫代碼，寫代碼不看視頻，偶爾實在不知道怎麼做了，再回去看視頻里怎麼做，一個視頻要看兩三遍。（稍微正了一些）

為了提高自己的打字速度，把手機的鍵盤從9鍵變成26鍵。（有一定作用但不是正道，推薦https://www.keybr.com/）

那時候我還心血來潮，趕VR潮流，在學校里搞起了VR工作室還有VR社團，但剛開始不做技術，是賣硬件的，賣手機紙盒子VR給學生。後來發現潮流過了，硬件沒前途，隨後就想把工作室往技術上轉，當時心裏的想法是邊能學Unity又能搞起一番事業（too young，too simple）。

大二的寒假里，我馬不停蹄，不斷學習SIKI公眾號上的項目案例，每做完一個就信心爆棚，彷彿自己已經是個優秀的遊戲程序員了。之後還在社團里教大家如何做一個AR應用，Unity小遊戲等等。

在大二的暑假里，我還認識了一個朋友，一起做汽車VR噴漆，想通過這個賺錢，但最終失敗了。同時，我發現專業偏硬件，於是我轉專業到計算機學院，開始了第二個大二生活。

旅途

後來的日子里，我依然是一有時間就跟着教程學，但彷彿到了一定的瓶頸，感覺做遊戲不就是調調api，用用插件，什麼遊戲都能做出來啊，恰巧當時看到心動在搞獨立營活動，我就立即報名了，這也成為了我第一次的gamejam。

gamejam的感覺呢，怎麼說呢，就好像回家了一樣，裏面各個都是人才，說話又好聽，超喜歡這裏面的~。在活動里，能夠充分體會到周圍人對遊戲的熱愛，精妙的遊戲設計，驚艷的美術，牛逼的程序老哥，主辦方給我們學生還特別優待，給我們免費訂了两天的五星級酒店，還包早餐，可惜都沒怎麼好好享受到，两天可能就住了8個小時不到吧，但整個活動充滿樂趣，給我的第一次gamejam留下了非常棒的印象。

之後便開始積极參加各種jam活動，線上線下到現在快應該有10場，每一次都很有收穫，無論是認識了新的朋友，還是看到了非常驚艷的遊戲，每次都是一場充電之旅。

里程碑

改變我職業生涯的是一次比賽。

還記得隔壁工作室的老哥問我一句有個AR的比賽來不來參加，我說來。那次比賽是一次hackthon，恰巧有一個單項獎由網易贊助，而且專門設置的AR題材。對我來說，我不了解hackthon，所以就把它當作是一場gamejam，看着周圍一圈985的同學們，壓力山大。

那次我們做了一個AR版本的胡鬧廚房，現在回想起來那代碼寫得就是一坨屎，但遊戲運行非常順暢，沒有bug，從可玩性來看還是挺不錯的，但和以前看的優秀作品比差距還是太遠。聽到主辦方在選出十個演講隊伍中沒有我們的名字時，我們已經收拾好行李，開始回校了。然鵝，這時候主辦方說不要急着走，網易的獎還沒開，我們一路就火急火燎的趕了回去。

由於來得太晚，演講已經開始了一大半，我們幾個人就站在入口的地方聽演講，看着別人的項目，什麼機器學習，區塊鏈，智能小車，各個高大上的不行，彷彿改變未來的技術一樣，而且沒有一個是做遊戲的，我這時候意識到，是不是走錯場了？

等其他獎開完了，才等到網易的負責人上台，大概是這麼說的，“我們在兩支隊伍里徘徊，所以一直沒能下一個定論，但最終我們在完整度上考慮，最終決定把一等獎給9號隊。”

當時整個人都已經懵逼了，周圍隊友興奮的握着我的手，這時候感到一切的努力都是值得的。

獲獎是次要的，最主要的是一等獎附贈一個網易終面機會，作為項目主程，我成功通過了，拿到了實習offer。

這次事件是里程碑，告訴我在這條路上繼續走下去是值得的。

泥潭

網易實習生活非常豐富，由於是實習生還是在一個偏創新的部門，我和周圍的小夥伴們一起做了非常多好玩有趣的AR遊戲，回來的我也是信心爆棚。

我繼續不斷學習，做項目。但做着做着發現，項目都能跑，但是最終的成品要想改功能，牽一發而動全身，最後改着改着就變成了一坨屎，而那些神乎其神的插件，自己始終停留在會用不會做的階段。

那時候的我非常的慌張，加群，逛知乎，看教程。最後我找到了一本遊戲設計模式，看完之後才知道，原來代碼能這麼寫，好方便啊，這之後代碼又上升了一個階段。

轉眼又一年經過，大三末的我又開始找實習。我本以為我那項目滿滿，經歷豐富的簡歷，一投一個准，做個offer收割機不是問題，然而事實就是，我就是a piece of shit。

算法，數據結構，計算機組成原理，是面試的重中之重，而這裏面每一個都是我的弱點，筆試都通不過。做了幾套面試題之後，我意識到，自己的基礎太弱了。

我開始瘋狂看面經，牛客網，leetcode，uwa也看。最終的出來一個結論，原來我就是個小白。

人貴有自知，知道自己多弱是件好事，至少知道自己要補哪些。這時候就非常感謝恭弘=叶 恭弘大的遊戲程序員學習路線，在書籍的指導下我決定從0開始，從primer cpp開始，從頭重新練，隨着一個個的知識點梳理過去，自己的知識漏洞逐漸補全。

一邊惡補一邊找工作，此時的我就是任人宰割的羔羊，哪家公司要我就去哪裡，大不了過半年，我又是一條好漢。

沒想到，本以為已經涼涼了的騰訊來了電話，那就索性面下去吧，沒想到一路面到了底，拿到了實習offer。。

升華

這次的實習和之前就完全不是一個感覺，正規的大項目，專業的導師，完善的框架，專業的團隊。據說實習留用率低，感覺壓力山大，一邊做着業務，一邊把手邊該看的基礎書在看。

這次依然運氣可以，上岸了。

回校之後，我開始繼續看基礎部分，但發現學習的面越來越廣，尤其是遊戲這塊更是複雜，因此，我逐漸放緩，雖然我的目標是做遊戲，但具體最終是做哪個職位的研究依然不夠清晰，甚至中途還打起了轉行做策劃的念頭。

我設立了第一個目標，搞一個框架。為什麼是這個目標？原因大致如下：

  • 目前我做了很多遊戲，都是小項目，做大了，代碼就變成一坨屎，攪都攪不動。
  • 框架可以讓項目變得有結構，是職業必經之路。
  • 想要做大項目，一定要有框架

我搜索了很多現有的框架，首先就是學着用，其中就包括strangeIoC，還有MVC等。不得不說，StrangeIoC是新手勸退框架，那一堆東西理念對初級程序員來說就是一頭霧水，明明三行就能實現的東西，為什麼要8個類幾百行實現。

偶然發現了一個QFramework，github千星項目，還有文檔，於是我就開始搞QFramework。

又是一個機會，發現QFramework的作者涼大準備搞事，做一個小班，專心帶學生，12月分期，學生還帶優惠，我轉念一想，當年SIKI還是個小公眾號，現在A計劃永久能賣大幾千，這個車一定要上。

交錢上車后，跟着涼大學，一天兩篇，框架搭建和shader都有涉及。有一說一，雖然是日更的，但是我一般三四天一看，甚至一周一看，剛開始比較勤勞，看得多，有一段時間看着比較累，就斷了一大片。

這裏非常感謝涼大時不時會來私聊，問問學習情況，有沒有遇到什麼困難。我當然也心知肚明，聊完就去補文章了。

正是在這樣的一步步過坎之後，自己的框架意識也逐步建立，共有問題也逐步顯現，C#上欠缺的部分通過中毒篇專欄有了很大的彌補，更重要的是，在未來的路途上有了專業的指導，少走了非常多的彎路，這點真的非常重要。

不知不覺間，一年就過去了，我也幸運的交上了一份畢業設計，學習過程中幾次差點放棄，但看看文章之後覺得這個知識有必要掌握，就一直續到了現在。

本來這篇文章是涼大讓我談談這個框架學習之路，扯了太多自己的東西，這裏就詳細聊聊框架的學習心得：

  • 課程內容里，最核心的還是框架學習，是主菜，至於shader部分，其實只是一個補充，比如業務里要用到相關知識，和專業技美或圖形程序不同，屬於副菜。
  • 文章講框架部分寫得非常好，由淺入深，講解細緻，且代碼詳盡，每一個學習單元都可以做一個小實現。
  • 記得涼大在學習開始的時候提到，小班文章的目的是讓大家看文章就行，不用做筆記，不用真的動手，看就完事了，但這一套在我這邊的嘗試下不太行的通，簡單的或者熟悉的內容可以一遍過，但一些需要反覆理解的如IoC部分，只看文章會覺得迷迷糊糊的。古人有句話，“紙上得來終覺淺，絕知此事要躬行”，對於難理解的內容，一定要下手嘗試，即使簡單的內容，親自做過之後都會有不一樣的感覺，有時間一定要多練習，偷懶只會虧待自己。
  • 明白最終自己想要的是什麼。由於課程涉及方方面面，學員的學習程度也層次不齊，有時候碰到的內容不感興趣，不是自己主要目標的組成部分，那便可以選擇性的不太需要花精力去學習，但這類情況較少，如果平時較為空閑，建議都看，有益無害。
  • 課程不太適合小白，適合有一定項目經驗的同學。
  • 剛開始會充滿激情，但中間會由於各種事情被打斷，最好養成一個看文章的固定時間段，比如996晚上摸魚的時候看，或者在周末挑一個時間。
  • 學習框架的過程為：使用框架to看懂框架to能寫框架，各自為階段，越過會導致許多障礙，比如沒有用過消息中心很難寫出一個消息中心
  • 不用害怕學不會，只要方向正確，沒有完成不了的

涼大在小班上非常負責，可以說關心到了每一個成員，內容質量也非常有保證，每每我有“棄坑”的想法時，涼大都會來“善意的提醒”。而我遇到什麼問題時，都能夠得到專業的回答。

大學的前幾年實際上走了不少彎路，如果能夠早期遇到專業的老師來指點的話能少走很多。如果入職一段時間了，職業提升遇到瓶頸，尤其還是從事Unity行業的話，那非常推薦來小班，這裏交流活躍，同行眾多，總有老哥給你指條明路。

在一年結束后，我也最終實現了我的目標，實現了自己的框架——HumanFramework，在大佬眼中應該就是個小不點的存在，但即使這個框架不會成為流行，這個過程也使我對軟件設計的理解更上了一層樓。

退潮

最近各種事情算是告一段落，畢業也好，小班也好，工作也好，自己的學生時代也結束了，即將開啟工作時代，由於之前的幾年坎坷奮鬥，加上自己的身體不算強健，現在留下了點胃病，這幾個月里都在養生，時不時看看業內新聞之類的，最近越來越對shader相關的內容感興趣了，之後的主要平台也會變為Unreal，想想也挺有趣的。

在這一年中，學到了很多，尤其是技術分享的重要性，自己也會寫一些文章分享出來，包括HumanFramework的製作過程分享，歡迎來知乎關注我

最終祝願所有讀者在學習的同時身體健康，身體是革命的本錢，有好的身體才有力氣追求更美好的生活。

轉載請註明地址：liangxiegame.com

更多內容

QFramework 地址：https://github.com/liangxiegame/QFramework
QQ 交流群：623597263
涼鞋的主頁：https://liangxiegame.com/zhuanlan
關注公眾號：liangxiegame 獲取第一時間更新通知及更多的免費內容。

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

綠色認證棕櫚油需要支持 監督機構訂新規 企業採購量不足將受罰

admin

環境資訊中心綜合外電；姜唯 編譯；林大利 審校

本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

Java併發包JUC核心原理解析

admin

CS-LogN思維導圖：記錄CS基礎 面試題
開源地址：https://github.com/FISHers6/CS-LogN

JUC

分類

線程管理

  • 線程池相關類

    • Executor、Executors、ExecutorService
    • 常用的線程池：FixedThreadPool、CachedThreadPool、ScheduledThreadPool、SingleThreadExecutor

  • 能獲取子線程的運行結果

    • Callable、Future、FutureTask

併發流程管理

  • CountDwonLatch、CyclicBarrier、Semaphore、Condition

實現線程安全

  • 互斥同步(鎖)

    • Synchronzied、及工具類Vector、Collections
    • Lock接口的相關類：ReentrantLock、讀寫鎖

  • 非互斥同(原子類)

    • 原子基本類型、引用類型、原子升級、累加器

  • 併發容器

    • ConcurrentHashMap、CopyOnWriteArrayList、BlockingQueue

  • 無同步與不可變方案

    • final關鍵字、ThreadLocal棧封閉

線程池

使用線程池的作用好處

  • 降低資源消耗

    • 重複利用已創建的線程降低線程創建和銷毀造成的消耗

  • 提高響應速度

    • 任務到達，可以不需要等到線程創建就能立即執行

  • 提高線程的可管理性

    • 使用線程池可以進行統一的分配，調優和監控

線程池的參數

  • corePoolSize、maximumPoolSize、keepAliveTime、workQueue、threadFactory、handler

  • 圖示

常用線程池的創建與規則

  • 線程添加規則

    • 1.如果線程數量小於corePoolSize，即使工作線程處於空閑狀態，也會創建一個新線程來運行新任務，創建方法是使用threadFactory

    • 2.如果線程數量大於corePoolSize但小於maximumPoolSize，則將任務放入隊列

    • 3.如果workQueue隊列已滿，並且線程數量小於maxPoolSize，則開闢一個非核心新線程來運行任務

    • 4.如果隊列已滿，並且線程數大於或等於maxPoolSize，則拒絕該任務，執行handler

    • 圖示(分別與3個參數比較)

  • 常用線程池

    • newFixedThreadPool

      • 創建固定大小的線程池，使用無界隊列會發生OOM

    • newSingleThreadExecutor

      • 創建一個單線程的線程池，線程數為1

    • newCachedThreadPool

      • 創建一個可緩存的線程池，60s會回收部分空閑的線程。採用直接交付的隊列 SynchronousQueue ，隊列容量為0，來一個創建一個線程

    • newScheduledThreadPool

      • 創建一個大小無限的線程池。此線程池支持定時以及周期性執行任務的需求

  • 如何設置初始化線程池的大小？

    • 可根據線程池中的線程
      處理任務的不同進行分別估計

      • CPU 密集型任務

        • 大量的運算，無阻塞
          通常 CPU 利用率很高
          應配置盡可能少的線程數量
          設置為 CPU 核數 + 1

      • IO 密集型任務

        • 這類任務有大量 IO 操作
          伴隨着大量線程被阻塞
          有利於并行提高CPU利用率
          配置更多數量： CPU 核心數 * 2

  • 使用線程池的注意事項

    • 1.避免任務堆積(無界隊列會OOM)、2.避免線程數過多(cachePool直接交付隊列)、3.排查線程泄露

線程池的狀態和常用方法

  • 線程池的狀態

    • RUNNING(接受並處理任務中)、
      SHUTDOWN(不接受新任務但處理排隊任務)、
      STOP(不接受新任務 也不處理排隊任務 並中斷正在進行的任務)、
      TIDYING、TEMINATED(運行完成)

  • 線程池停止

    • shutdown

      • 通知有序停止，先前提交的任務務會執行

    • shutdownNow

      • 嘗試立即停止，忽略隊列里等待的任務

線程池的源碼解析

  • 線程池的組成

    • 1.線程池管理器
      2.工作線程
      3.任務隊列：無界、有界、直接交付隊列
      4.任務接口Task

    • 圖示

  • Executor家族

    • Executor頂層接口，只有一個execute方法

    • ExecutorService繼承了Executor，增加了一些新的方法，比如shutdown擁有了初步管理線程池的功能方法

    • Executors工具類，來創建，類似Collections

    • 圖示

  • 線程池實現任務復用的原理

    • 線程池對線程作了包裝，不需要啟動線程，不需要重複start線程，只是調用已有線程固定數量的線程來跑傳進來的任務run方法

    • 添加工作線程

      • 4步：1. 獲取線程池狀態、4.判斷是否進入任務隊列 3.根據狀態檢測是否增加工作線程4.執行拒絕handler

    • 重複利用線程執行不同的任務

面試題

  • 為什麼要使用線程池？
  • 如何使用線程池？
  • 線程池有哪些核心參數？
  • 初始化線程池的大小的如何算？
  • shutdown 和 shutdownNow 有什麼區別？

ThreadLocal

ThreadLocal的作用好處

  • 為每個線程提供存儲自身獨立的局部變量，實現線程間隔離
  • 即：達到線程安全，不需要加鎖節省開銷，減少參數傳遞

ThreadLocal的使用場景

  • 1.每個線程需要一個獨享的對象，如 線程不安全的工具類，(線程隔離)
  • 2.每個線程內需要保存全局變量，如 攔截器中的用戶信息參數，讓不同方法直接使用，避免參數傳遞過多，(局部變量安全，參數傳遞）

ThreadLocal的實現原理

  • 每個 Thread 維護着一個 ThreadLocalMap 的引用；ThreadLocalMap 是 ThreadLocal 的內部類，用 Entry 來進行存儲；key就對應一個個ThreadLocal

  • get方法：取出當前線程的ThreadLocalMap，然後調用map.getEntry方法，把ThreadLocal作為key參數傳入，取出對應的value

  • set方法：往 ThreadLocalMap 設置ThreadLocal對應值
    initalValue方法：延遲加載，get的時候設置初始化

  • 圖示

缺陷注意

  • value內存泄漏

    • 原因：ThreadLocal 被 ThreadLocalMap 中的 entry 的 key 弱引用。如果 ThreadLocal 沒有被強引用， 那麼 GC 時 Entry 的 key 就會被回收，但是對應的 value 卻不會回收，就會造成內存泄漏

    • 解決方案：每次使用完 ThreadLocal，都調用它的 remove () 方法，清除value數據。

    • 源碼圖示

面試題

  • ThreadLocal 的作用是什麼？
  • 講一講ThreadLocal的實現原理(組成結構)
  • ThreadLocal有什麼風險？

Callable與Future

Callable

  • 引入目的

    • 解決Runnable的缺陷

      • 1.沒有返回值，因為返回類型為void
      • 2.不能拋出異常，因為沒有繼承Execption接口

  • 是什麼如何使用

    • Callable是類似於Runnable的接口，實現Callable接口的類和實現Runnable的類都是可被其它線程執行的任務。
    • 實現Call方法，可以有返回值

Future

  • 引入目的

    • Future的核心思想是：一個方法的計算過程可能非常耗時，一直在原地等待方法返回，顯然不明智。可以把該計算過程放到子線程去執行，並通過Future去控制方法的計算過程，在計算出結果后直接獲取該結果。

  • 常用方法

    • get方法：獲取結果，在沒有計算出結果前，會進入阻塞態

  • 使用場景

    • 用法1：線程池的submit方法返回Future對象
    • 用法2：用FutureTask來創建Future

  • 注意點

    • 當for循環批量獲取future的結果時，容易block，get方法調用時應使用timeout限制
    • Future和Callable的生命周期不能後退

  • Callable和Future的關係

    • Future相當於一個存儲器，它存儲未來call()任務方法的返回值結果

    • 可以用Future.get方法來獲取Callable接口的執行結果，在call()未執行完畢之前沒調用get的線程會被阻塞

    • 線程池傳入Callable，submit返回Future，get獲取值

  • FutureTask

    • FutureTask是一種包裝器，可以把Callable轉化成Future和Runnable，它同時實現了二者的接口。所以既可以作為Runnable任務被線程執行，又可以作為Future得到Callable的返回值

    • 圖示

final與不變性

什麼是不變性（Immutable）

  • 如果對象在被創建后，狀態就不能被修改，那麼它就是不可變的。
  • 具有不變性的對象一定是線程安全的，我們不需要對其採取任何額外的安全措施，也能保證線程安全。

final的作用

  • 類防止被繼承、方法防止被重寫、變量防止被修改
  • 天生是線程安全的(因為不能修改)，而不需要額外的同步開銷

final的3種用法：修飾變量、方法、類

  • final修飾變量

    • 被final修飾的變量，意味着值不能被修改。
      如果變量是對象，那麼對象的引用不能變，但是對象自身的內容依然可以變化。

    • 賦值時機

      • 屬性被聲明為final后，該變量則只能被賦值一次。且一旦被賦值，final的變量就不能再被改變，如論如何也不會變。

      • 區分為3種

        • final instance variable（類中的final屬性）

          • 等號右側、構造函數、初始化代碼塊

        • final static variable（類中的static final屬性）

          • 等號右側、靜態初始化代碼塊

        • final local variable（方法中的final變量）

          • 使用前複製即可

      • 為什麼規定時機

        • 根據JVM對類和成員變量、靜態成員變量的加載規則來看：如果初始化不賦值，後續賦值，就是從null變成新的賦值，這就違反final不變的原則了！

  • final修飾方法（構造方法除外）

    • 不可被重寫，也就是不能被override，即便是子類有同樣名字的方法，那也不是override，與static類似*

  • final修飾類

    • 不可被繼承，例如典型的String類就是final的

棧封閉 實現線程安全

  • 在方法里新建的局部便咯，實際上是存儲在每個線程私有的棧空間，線程棧不能被其它線程訪問，所以不會有線程安全問題，如ThreadLocal

面試題

CAS

什麼是CAS

  • 我認為V的值應該是A，如果是的話那我就把它改成B，如果不是A（說明被別人修改過了），那我就不修改了，避免多人同時修改導致出錯。
  • CAS有三個操作數：內存值V、預期值A、要修改的值B，當且僅當預期值A和內存值V相同時，才將內存值修改為B，否則什麼都不做。最後返回現在的V值。
  • 最終執行CPU處理機提供的的原子指令

缺點

  • ABA問題

    • 我認為 V的值為A，有其它線程在這期間修改了值為B，但它又修改成了A，那麼CAS只是對比最終結果和預期值，就檢測不出是否修改過

  • CAS+自旋，導致自旋時間過長

  • 改進：通過版本號的機制來解決。每次變量更新的時候，版本號加 1，如AtomicStampedReference的compareAndSet ()

應用場景

  • 1 樂觀鎖：數據庫、git版本號； 自旋 2 concurrentHashMap：CAS+自旋
    3 原子類

CAS底層實現

  • 通過Unsafe獲取待修改變量的內存遞增，
    比較預期值與結果，調用彙編cmpxchg指令

以AtomicInteger為例，分析在Java中是如何利用CAS實現原子操作的？

  • 1.使用Unsafe類拿到value的內存遞增，通過偏移量 直接操作內存數據
  • 2.Unsafe的getAndAddInt方法，使用CAS+自旋嘗試修改數據
  • CAS的參數通過 預期值 與 實際拿到的值進行比較，相同就修改，不相同就自旋
  • Unsafe提供硬件級別的原子操作，最終調用原子彙編指令的cmpxchg指令

鎖

鎖的分類

Lock鎖接口

  • 簡介

    • Lock鎖是一種工具，用於控制對共享資源的訪問
    • 如：ReentrantLock

  • Lock和Synchronized的異同點

    • 相同點

      • 都能達到線程安全的目的

    • 不同點

      • Lock 有比 synchronized 更精確的線程語義和更好的性能；高級功能

      • 1 實現原理不同

        • Synchronized 是關鍵字，屬於 JVM 層面，底層是通過 monitorenter 和 monitorexit 完成，依賴於 monitor 對象來完成；
        • Lock 是 java.util.concurrent.locks.lock 包下的，底層是AQS

      • 2 靈活性不同

        • Synchronized 代碼完成之後系統自動讓線程釋放鎖；ReentrantLock 需要用戶手動釋放鎖，加鎖解鎖靈活

      • 3 等待時是否可以中斷

        • Synchronized 不可中斷，除非拋出異常或者正常運行完成；ReentrantLock 可以中斷。一種是通過 tryLock，另一種是 lockInterruptibly () 放代碼塊中，調用 interrupt () 方法進行中斷；

  • 可見性

    • happens-before規則約定；Lock與Synchronized一致都可以保證可見性
    • 即下一個線程加鎖時可以看到上一個釋放鎖的線程發生的所有操作

樂觀鎖與悲觀鎖

  • 悲觀鎖(互斥同步鎖)

    • 思想

      • 鎖住數據，讓別人無法訪問，確保數據萬無一失

    • 實例

      • Synchronized、Lock相關類
      • 應用實例：select 把庫鎖住，屬於悲觀鎖，更新期間其它人不能修改

    • 缺點

      • 在阻塞和喚醒性能開銷大(用戶態核心態切換、上下文切換、檢查是否有線程被喚醒)
      • 持有鎖的線程被阻塞時無法釋放，有可能造成永久阻塞

  • 樂觀鎖

    • 思想

      • 認為自己在操作數據時不會有其它線程干擾，所以不需要鎖住被操作對象
      • 在更新數據的時候，去對比修改期間有沒有被其它人改變過，沒改過就正常修改(類似CAS思想)
      • 樂觀鎖一般由CAS實現：CAS在一個原子操作內把數據對比且交換，在此期間不能被打斷的

    • 實例

      • 原子類、併發容器
      • 應用實例：數據庫版本號控制、git版本號

    • 優缺點對比

      • 悲觀鎖一旦切換就不用再考慮切換CPU等操作了，一勞永逸，開銷固定
      • 樂觀鎖，會一步步嘗試自旋來獲取鎖，自旋開銷

  • 對比

可重入鎖與非可重入鎖

  • 什麼是可重入

    • 拿到鎖的線程又請求這把鎖，允許通過

  • 可重入的好處

    • 避免死鎖(拿到鎖的線程內部又請求該鎖)
    • 提升封裝性，避免一次次加鎖

  • 可重入鎖ReentrantLock與非可重入鎖ThreadPoolExecutor的Worker類對比

公平鎖和非公平鎖

  • 公平鎖

    • 介紹

      • 公平鎖是指多個線程按照申請鎖的順序來獲取鎖，線程直接進入隊列中排隊，隊列中的第一個線程才能獲得鎖

    • 優點

      • 公平鎖的優點是公平執行，等待鎖的線程不會餓死

    • 缺點

      • 缺點是整體吞吐效率相對非公平鎖要低，等待隊列中除第一個線程以外的所有線程都會阻塞，CPU喚醒阻塞線程的開銷比非公平鎖大

  • 非公平鎖

    • 介紹

      • 多個線程加鎖時直接嘗試獲取鎖，獲取不到才會到等待隊列的隊尾等待。但如果此時鎖剛好可用，那麼這個線程可以無需阻塞直接獲取到鎖，所以非公平鎖有可能出現后申請鎖的線程先獲取鎖的場景

    • 優點

      • 減少喚起線程的開銷，整體的吞吐效率高，因為線程有幾率不阻塞直接獲得鎖，CPU不必喚醒所有線程

    • 缺點

      • 處於等待隊列中的線程可能會餓死，或者等很久才會獲得鎖

  • 優缺點對比

  • 源碼分析

共享鎖和排他鎖

  • 排他鎖

    • 介紹

      • 排他鎖，獲取鎖后，既能讀又能寫，但是此時其它線程不能獲取這個鎖了，只能由當前線程修改數據獨享鎖，保證了線程安全，synchronized
      • 又稱為 獨佔鎖，寫鎖

  • 共享鎖

    • 介紹

      • 獲取共享鎖后，其它線程也可以獲取共享鎖完成讀操作，但都不能修改刪除數據
      • 又成為 讀鎖

  • ReentrantReadWriteLock

    • 讀寫鎖的作用

      • 共享鎖減少了多個讀都加鎖的開銷，線程也安全
      • 在讀的地方使用讀鎖，在寫的地方寫鎖；在沒有寫鎖的情況下，讀操作無阻塞，提高程序效率

    • 讀寫鎖的規則

      • 要麼可以多讀，要麼只能一寫
      • 讀寫鎖只是一把鎖，可以通過兩個方式鎖定：讀鎖定 或 寫鎖定

    • 一把鎖兩種方式鎖定

      • readLock() 讀鎖
      • writeLock() 寫鎖

    • 讀線程插隊策略(非公平下)

      • 寫鎖可以隨時插隊，參与競爭
      • 讀鎖僅在等待隊列頭節點為寫的時候不允許插隊；當隊頭為讀的時候可以去插隊。

    • 鎖升級

      • 引入場景

        • 假如一開始持有寫鎖，但我寫需求完了，後面都是讀的需求了，如果還佔用寫鎖就浪費資源開銷

      • 策略

        • 只允許降級，不允許升級

    • 適合場景

      • 讀多寫少，提高併發效率

自旋鎖和阻塞鎖

  • 阻塞鎖

    • 思想

      • 沒拿到鎖之前，會直接把線程阻塞，直到被喚醒

    • 開銷缺陷

      • 阻塞或喚醒一個線程需要操作系統切換CPU狀態來完成，恢復現場等需要消耗處理機時間；如果同步代碼塊的內容過於簡單，狀態轉換消耗的時間有可能比用戶代碼執行的時間還要長，得不償失

  • 自旋鎖

    • 思想

      • 讓當前搶鎖失敗的線程進行自旋，如果在自旋完成后前面鎖定同步資源的線程已經釋放了鎖，那麼當前線程就可以不必阻塞而是直接獲取同步資源，從而避免切換線程的開銷

    • 開銷缺陷

      • 自旋佔用時間長，起始開銷低，但消耗CPU資源開銷會線性增長

  • 源碼分析

    • atomic包下的類基本都是自旋鎖的實現

    • AtomicInteger的實現：自旋鎖實現原理是CAS，Atomic調用Unsafe進行自增add的源碼中的do-while循環就是一個自旋操作，使用CAS如果修改過程中遇到其它線程修改導致沒有秀嘎四成功，就在while里死循環，直至修改成功

    • 圖示

  • 適用場景

    • 多核、臨界區短小

可中斷鎖

  • 介紹

    • 線程B等待線程A釋放鎖時，線程B不想等待了，想處理其它事情，我們可以中斷它

  • 使用場景

    • synchronized是不可中斷鎖，Lock是可中斷鎖(tryLock(time) 和 lockInterruptibly)響應中斷

鎖優化

  • JDK1.6 后對synchronized鎖的優化

    • JDK1.6 對鎖的實現引入了大量的優化，如偏向鎖、輕量級鎖、自旋鎖、適應性自旋鎖、鎖消除、鎖粗化等技術來減少鎖操作的開銷。

    • 偏向鎖

      • 無競爭條件下,消除整個同步互斥，連CAS都不操作；即這個鎖會偏向於第一個獲得它的線程

    • 輕量級鎖

      • 無競爭條件下,通過CAS消除同步互斥，減少傳統的重量級鎖使用操作系統互斥量產生的性能消耗。

    • 重量級鎖

      • 互斥同步鎖

    • 自旋鎖

      • 為了減少線程狀態改變帶來的消耗,不停地執行當前線程

    • 自適應自旋鎖

      • 自旋的時間不固定了，如設置自旋次數

    • 鎖消除

      • 不可能存在共享數據競爭的鎖進行消除；

    • 鎖粗化

      • 鎖粗化就是增大鎖的作用域；如解決加鎖操作在循環體內的頻開銷

  • 寫代碼時的優化

    • 縮小同步代碼塊、如不要鎖住方法
    • 減少鎖的請求次數， 如一批一批請求
    • 參考LongAdder的思想，每個段有自己的計數器，最後才合併

面試題

  • 什麼是公平鎖？什麼是非公平鎖？
  • 自旋鎖解決什麼問題?自旋鎖的原理是什麼?自旋的缺點?
  • 說說 JDK1.6 之後的synchronized 關鍵字底層做了哪些優化，可以詳細介紹一下這些優化嗎？
  • 說說 synchronized 和 java.util.concurrent.locks.Lock 的異同？

原子類atomic包

原子類的作用

  • 原子類的作用和鎖類似，都是為了保證併發下線程安全
  • 粒度更細，變量級別
  • 效率更高，除了高度競爭外

原子類的種類

  • Atomic*基本類型原子類：AtomicInteger、AtomicLong、AtomicBoolean
  • Atomic*Array數組類型原子類：AtomicIntegerArray、AtomicLongArray、AtomicReferenceArray
  • Atomic*Reference 引用類型原子類：AtomicReference等
  • AtomicIntegerFiledUpdate等升級類型原子類
  • Adder累加器、Accumlator累加器

AtomicInteger

  • 常用方法

    • get、getAndSet、getAndIncrement、compareAndSet(int expect,int update)

  • 實現原理

    • AtomicInteger 內部使用 CAS 原子語義來處理加減等操作。CAS通過判斷內存某個位置的值是否與預期值相等，如果相等則進行值更新
    • CAS 是內部是通過 Unsafe 類實現，而 Unsafe 類的方法都是 native 的，在 JNI 里是藉助於一個 CPU 指令完成的，屬於原子操作。

  • 缺點

    • 循環開銷大。如果 CAS 失敗，會一直嘗試
    • 只能保證單個共享變量的原子操作，對於多個共享變量，CAS 無法保證，引出原子引用類
    • 用CAS存在 ABA 問題

Adder累加器

  • 引入目的/改進思想

    • AtomicLong在每一次加法都要flush和refresh主存，與JMM內存模型有關。工作線程之間不能直接通信，需要通過主內存間接通信

  • 設計思想

    • Java8引入，高併發下LongAdder比AtomicLong效率高，本質是空間換時間
    • 競爭激烈時，LongAdder把不同線程對應到不同的Cell單元上進行修改，降低了衝突的概率，是多段鎖的理念，提高了併發性
    • 每個線程都有自己的一個計數器，不存在競爭
    • sum源碼分析：最終把每一個Cell的計數器與base主變量相加

面試題

  • AtomicInteger 怎麼實現原子操作的？
  • AtomicInteger 有哪些缺點？

併發容器

ConcurrentHashMap

  • 集合類歷史

    • Vector的方法被synchronizd修飾，同步鎖；不允許多個線程同時執行。併發量大的時候性能不好
    • Hashtable是線程安全的HashMap，方法也是被synchronized修飾，同步但併發性能差
    • Collections工具類，提高的有synchronizedList和synchronizedMap，代碼內使用sync互斥變量加鎖

  • 為什麼需要

    • 為什麼不用HashMap

      • 1.多線程下同時put碰撞導致數據丟失
      • 2.多線程下同時put擴容導致數據丟失
      • 3.死循環造成的CPU100%

    • 為什麼不用Collection.synchronizedMap

      • 同步鎖併發性能低

  • 數據結構與併發策略

    • JDK1.7

      • 數組+鏈表，拉鏈法解決衝突
      • 採用分段鎖，每個數組結點是一個獨立的ReentrantLock鎖，可以支持同時併發寫

    • JDK1.8

      • 數組+鏈表+紅黑樹，拉鏈法和樹化解決衝突
      • 採用CAS+synchronized鎖細化

    • 1.7到1.8改變後有哪些優點

      • 1.數據結構由鏈表變為紅黑樹，樹查詢效率更高
      • 2.減少了Hash碰撞，1.7拉鏈法
      • 3.保證了併發安全和性能，分段鎖改成CAS+synchronized
      • 為什麼超過8要轉為紅黑樹，因為紅黑樹存儲空間是結點的兩倍，經過泊松分佈，8衝突概率低

  • 注意事項

    • 組合操作線程不安全，應使用putIfAbsent提供的原子性操作

CopyOnWriteArrayList

  • 引入目的

    • Vector和SynchronizedList鎖的粒度太大併發效率低，並且迭代時無法編輯exceptMod!=Count

  • 適合場景

    • 讀多寫少，如黑名單管理每日更新

  • 讀寫規則

    • 是對讀寫鎖的升級：讀取完全不用加鎖，讀時寫入也不會阻塞。只有寫入和寫入之間需要同步

  • 實現原理

    • 創建數據的新副本，實現讀寫分離，修改時整個副本進行一次複製，完成后最後再替換回去；由於讀寫分離，舊容器不變，所以線程安全無需鎖
    • 在計算機內存中修改不直接修改主內存，而是修改緩存(cache、對拷貝的副本進行修改)，再進行同步(指針指向新數據)。

  • 缺點

    • 1.數據一致性問題，拷貝不能保證數據實時一致，只能保證數據最終一致性
    • 2.內存佔用問題，寫複製機制，寫操作時內存會同時駐紮兩個對象的內存

併發隊列

  • 為什麼使用隊列

    • 用隊列可以在線程間傳遞數據，緩存數據
    • 考慮鎖等線程安全問題的重任轉移到了“隊列”上

  • 併發隊列關係圖示

  • BlockingQueue阻塞隊列

    • 阻塞隊列是局由自動阻塞功能的隊列，線程安全；take方法移除隊頭，若隊列無數據則阻塞直到有數據；put方法插入元素，如果隊列已滿就無法繼續插入則阻塞直到隊列里有了空閑空間

    • ArrayBlockQueue

      • 有界可指定容量、可公平
      • Put源碼加鎖，可中斷的上鎖方法。沒滿才可以入隊，否則一直await等待。

    • LinkedBlockingQueue

      • 無界容量為MAX_VALUE，內部結構Node
      • 使用了兩把鎖take鎖和put鎖互補干擾

    • PriorityBlockingQueue

      • 支持優先級，無界隊列

    • SynchronousQueue

      • 直接傳遞的隊列，容量0，效率高線程池的CacheExecutorPool使用其作為工作隊列

    • DelayQueue

      • 無界隊列，根據延遲時間排序

  • 非阻塞隊列

    • ConcurrentLinkedQueue

      • 使用鏈表作為隊列存儲結構
      • 使用Unsafe的CAS非阻塞方法來實現線程安全，無需阻塞，適合對性能要求較高的併發場景

  • 選擇合適的隊列

    • 邊界上看

      • ArrayBlockQueue有界；LinkedBlockQueue無界適合容量大容量激增

    • 內存上看

      • ArrayBlockQueue內部結構是array，從內存存儲上看，連續存儲更加整齊。而LinkedBlockQueue採用鏈表結點，可以非連續存儲。

    • 吞吐量上看

      • 從性能上看LinkedBlockQueue的put鎖和鎖分開，鎖粒度更細，所以優於ArrayBlockQueue

總結併發容器對比

  • 分為3類：Concurrent、CopyOnWrite、Blocking*
  • Concurrent*的特定是大部分使用CAS併發；而CopyOnWrite通過複製一份元數據寫加鎖實現；Blocking通過ReentLock鎖底層AQS實現

併發流程控制工具類

控制併發流程工具類的作用

  • 控制併發流程的工具類，作用是幫助程序員更容易讓線程之間相互配合，來滿足業務邏輯

  • 併發工具類圖示

CountDownLatch倒計時門閂

  • 作用(事件)

    • 一個線程等多個線程、或多個線程等一個線程完成到達，才能繼續執行

  • 常用方法

    • 構造函數中傳入倒數值、await、countDown

Semaphore信號量

  • 作用

    • 用來限制管理數量有限的資源的使用情況，相當於一定數量的“許可證”

  • 常用方法

    • 構造函數中傳入數量、acquire、release

Condition條件對象

  • 作用

    • 等待條件滿足才放行，否則阻塞；一個鎖可以對應多個條件

  • 常用方法

    • lock.newCondition、await、signal

CyclicBarrier循環柵欄

  • 作用(線程)

    • 多個線程互相等待，直到達到同一個同步點（屏障），再繼續一起執行

  • 常用方法

    • 構造函數中傳入個數、await

AQS

AQS的作用

  • AQS是一個用於構建鎖、同步器、協作工具類的框架，有了AQS后，更多的協作工具類都可以很方便的寫出來

AQS的應用場景

  • Exclusive(獨佔)

    • ReentrantLock 公平和非公平鎖

  • Share(共享)

    • Semaphore/CountDownLatch/CyclicBarrier

AQS原理解析

  • 核心三要素

    • 1.sate

      • 使用一個 int 成員變量來表示同步狀態 state，被volatile修飾，會被併發修改，各方法如getState、setState等使用CAS保證線程安全
      • 在ReentrantLock中，表示可重入的次數
      • 在Semaphore中，表示剩餘許可證信號的數量
      • 在CountDownLatch中，表示還需要倒數的個數

    • 2.控制線程搶鎖和配合的FIFO隊列

      • 獲取資源線程的排隊工作

    • 3.期望協作工具類去實現的“獲取/釋放”等喚醒分配的方法策略

  • AQS的用法

    • 第一步：寫一個類，想好協作的邏輯，實現獲取/釋放方法
    • 第二步：內部寫一個Sync類繼承AbstractQueueSynchronizer
    • 第三步：Sync類根據獨佔還是共享重寫tryAcquire/tryRelease或tryAcquireShared和tryReleaseShared等方法，在之前寫的獲取/釋放方法中調用AQS的acquire/release或則Shared方法

AQS應用實例源碼解析

  • AQS在CountDownLatch的應用

    • 內部類Sync繼承AQS

    • 1.state表示門閂倒數的count數量，對應getCount方法獲取

    • 2.釋放方法，countDown方法會讓state減1，直到減為0時就喚醒所有線程。countDown方法調用releaseShared，它調用sync實現的tryReleaseShared，其使用CAS+自旋鎖，來實現安全的計數-1

    • 3.阻塞方法，await會調用sync提供的aquireSharedInterruptly方法，當state不等於0時，最終調用LockUpport的park，它利用Unsafe的park，native方法，把線程加入阻塞隊列

    • 總結

  • AQS在Semphore的應用

    • state表示信號量允許的剩餘許可數量

    • tryAcquire方法，判斷信號量大於0就成功獲取，使用CAS+自旋改變state狀態。如果信號量小於0了，再請求時tryAcquireShared返回負數，調用aquireSharedInterruptly方法就進入阻塞隊列

    • release方法，調用sync實現的releaseShared，會利用AQS去阻塞隊列喚醒一個線程

    • 總結

  • AQS在ReentrantLock的應用

    • state表示已重入的次數，獨佔鎖權保存在AQS的Thread類型的exclusiveOwnerThread變量中
    • 釋放鎖: unlock方法調用sync實現的release方法，會調用tryRelease，使用setState而不是CAS來修改重入次數state，當state減到0完全釋放鎖
    • 加鎖lock方法：調用sync實現的lock方法。CAS嘗試修改鎖的所有權為當前線程，如果修改失敗就要調用acquire方法再次嘗試獲取，acquire方法調用了AQS的tryAcquire，這個實現在ReentantLock的裏面，獲取失敗加入到阻塞隊列

通過AQS自定義同步器

  • 自定義同步器在實現時只需要根據業務邏輯需求，實現共享資源 state 的獲取與釋放方式策略即可
  • 至於具體線程等待隊列的維護（如獲取資源失敗入隊 / 喚醒出隊等），AQS 已經在頂層實現好了

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

Celery淺談

admin

一、Celery 核心模塊

1. Brokers

brokers 中文意思為中間人，在這裏就是指任務隊列本身，接收生產者發來的消息即Task，將任務存入隊列。任務的消費者是Worker，Brokers 就是生產者和消費者存放/拿取產品的地方(隊列)。Celery 扮演生產者和消費者的角色。

常見的 brokers 有 rabbitmq、redis、Zookeeper 等。推薦用Redis或RabbitMQ實現隊列服務。

2. Workers

就是 Celery 中的工作者，執行任務的單元，類似與生產/消費模型中的消費者。它實時監控消息隊列，如果有任務就從隊列中取出任務並執行它。

3. Backend / Result Stores

用於存儲任務的執行結果。隊列中的任務運行完后的結果或者狀態需要被任務發送者知道，那麼就需要一個地方儲存這些結果，就是 Result Stores 了。

常見的 backend 有 redis、Memcached 甚至常用的數據庫都可以。

4. Tasks

就是想在隊列中進行的任務，有異步任務和定時任務。一般由用戶、觸發器或其他操作將任務入隊，然後交由 workers 進行處理。

5. Beat

定時任務調度器，根據配置定時將任務發送給Brokers。

二、Celery 基本使用

1.創建一個celery application 用來定義你的任務列表，創建一個任務文件就叫tasks.py吧。

from celery import Celery
 
# 配置好celery的backend和broker
app = Celery('task1',  backend='redis://127.0.0.1:6379/0', broker='redis://127.0.0.1:6379/0')
  
#普通函數裝飾為 celery task
@app.task 
def add(x, y):
    return x + y

如此而來，我們只是定義好了任務函數func函數和worker(celery對象)。worker相當於工作者。

2.啟動Celery Worker來開始監聽並執行任務。broker 我們有了，backend 我們有了，task 我們也有了，現在就該運行 worker 進行工作了，在 tasks.py 所在目錄下運行：

[root@localhost ~]# celery -A tasks worker --loglevel=info    # 啟動方法1
[root@localhost ~]# celery -A tasks worker --l debug          # 啟動方法2

現在 tasks 這個任務集合的 worker 在進行工作（當然此時broker中還沒有任務，worker此時相當於待命狀態），如果隊列中已經有任務了，就會立即執行。

3.調用任務：要給Worker發送任務，需要調用 delay() 方法。

import time
from tasks import add
 
# 不要直接add(6, 6)，這裏需要用 celery 提供的接口 delay 進行調用
result = add.delay(6, 6)
while not result.ready():
    time.sleep(1)
print('task done: {0}'.format(result.get()))

三、Celery 進階使用

1.celery_config.py：配置文件

from __future__ import absolute_import, unicode_literals
#從python的絕對路徑導入而不是當前的腳本     #在python2和python3做兼容支持的
 
BROKER_URL = 'redis://127.0.0.1:6379/0'
# 指定結果的接受地址
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/0'

2.tasks.py

from __future__ import absolute_import, unicode_literals
#從python的絕對路徑導入而不是當前的腳本     #在python2和python3做兼容支持的
from celery import Celery
 
# 配置好celery的backend和broker, task1:app的名字。broker
app = Celery('task1',                              #
             broker='redis://127.0.0.1:6379/0',   # 消息隊列：連rabbitmq或redis
             backend='redis://127.0.0.1:6379/0')  # 存儲結果：redis或mongo或其他數據庫
  
app.config_from_object("celery_config")
app.conf.update(         # 給app設置參數
    result_expires=3600, # 保存時間為1小時
)
 
#普通函數裝飾為 celery task
@app.task 
def add(x, y):
    return x + y
     
if __name__ == '__main__':
    app.start()

3.啟動worker

[root@localhost ~]``# celery -A tasks worker --loglevel=info

4.test.py

import time
from tasks import add
 
# 不要直接add(4, 4)，這裏需要用 celery 提供的接口 delay 進行調用
result = add.delay(6, 6)
print(result.id)
while not result.ready():
    time.sleep(1)
print('task done: {0}'.format(result.get()))

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

助力新能源車 意法半導體推新款車規碳化矽二極體

admin

意法半導體推出新款車規碳化矽（SiC）二極體，以滿足電動汽車和插電式混合動力車（PHEVs，Plug-in Hybrids）等新能源汽車對車載充電器（OBCs，on-board battery chargers）在有限空間內處理大功率的苛刻要求。  

  新款二極體採用先進的技術可防止高電流突波燒毀裝置，其過電流保護是額定電流的2.5倍，因此設計人員可選用更小、更經濟實惠且可靠性和效能都不會受到影響的電流更小的二極體。此新碳化矽二極體通過車規產品測試，反向擊穿電壓提高到650V，能滿足設計人員和汽車廠商欲降低電壓補償係數的要求，以確保車載充電半導體元件的標準與瞬間峰值電壓之間有充足的安全邊際。   這次推出的650V二極體包括TO-220AC功率封裝的10A STPSC10H065DY和TO-220AC封裝的12A STPSC12H065DY。此外，TO-220AB封裝的STPSC20H065CTY和TO-247封裝的STPSC20H065CWY是內建２個10A二極體的雙二極體（dual-diode ）產品，可最大幅度地提升空間利用度並減少車載充電器的重量。

本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

擴大電動車布局 鴻海入股中國和諧汽車

admin

鴻海於 12 月 22 日公告，以台幣約 24.84 億元入股中國和諧汽車（China Harmony Auto Holding Limited），取得 10.526% 的持股，未來雙方將展開新能源、電動車的通路合作。   和諧汽車為中國進口高級品牌汽車的第二大經銷商，擁有 25 個銷售據點，旗下代理品牌超過 10 個，包括寶馬、勞斯萊斯，MINI、奧迪、法拉利、瑪莎拉蒂等等。   而鴻海集團近來在電動車市場投資與布局也動作頻頻，鴻海集團總裁郭台銘 12 月初率領近 20 人的專家團隊，前往河南首三門峽市的速達電動汽車公司進行實地考察，並駕駛了速達電動車，正式開啟了合作契機。緊接著，富士康與北汽合資電動車租賃公司也傳出獲得中國科技局採用的好消息，成功打入當地電動車租賃市場。   這次，由鴻海主動發布重大訊息，代子公司 Foxconn (Far East) Limited 公告為了與目標公司合作發展新事業，將投資和諧汽車，以港幣約 6.09 億元（約台幣 24.84 億元），每股港幣 4.73 元，取得和諧汽車股份，持股比例將達到 10.526%。   (照片來源：)

本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案