Posted 2021-04-06 浠ｇ爜鑽ｈ€€

纰庣墖鏃堕棿|浣撶郴瀛︿範

杩欐槸绋嬪簭鍛楥hatbook绗?span>84绡囧師鍒?/span>

璺濈2018骞磋繕鏈?/span>3澶?/span>

 浠婃棩闅惧害绯绘暟 锛氿煂燄煂燄煂?/p>

棰勮闃呰鏃堕棿 锛?nbsp;3 鍒嗛挓

鈻?/span>

00銆佷粠涓€涓緥瀛愯皥璧?/strong>

鏃堕棿锛氫负浜嗚兘鏇村姞璇存槑闂锛岃鎴戜滑鎶婃椂闂撮€€鍥炲埌10骞村墠锛岄偅涓椂鍊欒繕娌℃湁鎵€璋撶殑鎺掗槦鍙彿鏈嶅姟锛屼负浜嗗姙鐞嗘煇绉嶄笟鍔¤繕闇€瑕佹帓闃熺殑閭ｄ釜骞翠唬銆?/p>

鍦烘櫙锛氭煇鍦扮殑鏌愰摱琛岃惀涓氬巺鏌滃彴寮€浜?涓獥鍙?/strong>锛屾瘡涓獥鍙ｉ噷闈㈤兘鍧愪簡涓€浣嶅伐浣滀汉鍛橈紱褰撳偍钃勭敤鎴锋潵鍒伴摱琛屽ぇ鍘呭悗锛岀湅瑙佹湁绐楀彛鏄┖闂茬殑锛岄偅涔堝氨鍙互鐩存帴鍓嶅線绌洪棽鐨勭獥鍙ｅ幓鍔炵悊涓氬姟锛涙參鎱㈠湴锛屽埌閾惰鍔炵悊鍌ㄨ搫涓氬姟鐨勪汉瓒婃潵瓒婂浜嗭紝8涓獥鍙ｉ兘鍦ㄥ澶栨彁渚涙湇鍔★紱杩欎釜鏃跺€欙紝鏂板埌鐨勫鎴峰氨鍙兘杩涜鎺掗槦銆?/p>

濡傛灉鏂版潵瀹㈡埛鐨勫闀块€熷害杩滆繙澶т簬閾惰宸ヤ綔浜哄憳瀹屾垚涓€椤瑰鎴蜂笟鍔＄殑閫熷害锛岃繖鏍峰鎴锋帓闃熷氨浼氳秺绉秺澶氥€傝繖鏃跺€欙紝閾惰鐨勫ぇ鍫傜粡鐞嗗彲鑳戒細澧炲紑2涓复鏃剁獥鍙?/strong>涓烘帓闃熺殑瀹㈡埛鎻愪緵鏈嶅姟銆?/p>

閭ｇ煡閬撲粖澶╂槸闄ゅ锛岃繃鏉ュ姙鐞嗗偍钃勪笟鍔″鎴疯秺鏉ヨ秺澶氾紝10锛?+2锛変釜绐楀彛涔熶笉澶熺敤浜嗭紝杩欎釜鏃跺€欏ぇ鍫傜粡鐞嗗彲鑳藉氨瑕佽€冭檻涓嶅啀鎺ユ敹鏂板鎴锋垨瑙勫姖锛?span>鎶涘純锛夌幇鍦ㄦ帓闃熺殑瀹㈡埛鍘诲氨杩戠殑閾惰钀ヤ笟鍘呭幓鍔炵悊涓氬姟浜嗐€?/p>

鏃堕棿鍒颁簡涓嬪崍锛岃繃鏉ュ姙鐞嗗偍钃勪笟鍔＄殑瀹㈡埛瓒婃潵瓒婂皯浜嗭紙鍙兘澶у閮藉幓鍑嗗骞村楗簡锛夛紝澶у爞缁忕悊鍙戠幇鏂板鐨?涓复鏃剁獥鍙ｇ┖闂插悗锛屽張绛夊緟瑙傚療浜?0鍒嗛挓鍚庯紝鍙戠幇绌洪棽渚濇棫锛屽彲鑳藉氨瑕佽€冭檻鎶婁箣鍓嶇殑2涓复鏃剁獥鍙ｅ叧闂?/strong>浜嗭紝鍙繚鐣欎箣鍓嶇殑8涓獥鍙ｃ€?/p>

濂戒簡锛屼緥瀛愯瀹屼簡锛岃€侀搧浠竴瀹氭兂鍒颁簡锛屼笂杩扮殑渚嬪瓙鍙槸瀵圭嚎绋嬫睜宸ヤ綔杩囩▼鐨勪竴涓舰璞″寲姣斿柣銆備笅闈㈡垜浠ThreadPoolSize鍐嶆鐧诲満锛屽浠ｇ爜1鎵€绀猴細

1

public ThreadPoolExecutor(int corePoolSize,
 int maximumPoolSize,
 long keepAliveTime,
                TimeUnit unit,
 BlockingQueue<Runnable> workQueue,
 ThreadFactory threadFactory,
 RejectedExecutionHandler handler);

浠ｇ爜1涓槸ThreadPoolExecutor鐨勬瀯閫犲嚱鏁帮紝鍏跺弬鏁板惈涔夊涓嬶細

• corePoolSize锛氭寚瀹氫簡绾跨▼姹犱腑鐨勭嚎绋嬫暟閲忥紱鎸囦唬鈥滀笂渚嬩腑鐨?涓獥鍙ｂ€?/p>

• maximumPoolSize锛氭寚瀹氫簡绾跨▼姹犱腑鐨勬渶澶х嚎绋嬫暟閲忥紱鎸囦唬鈥滀笂渚嬩腑鐨?0涓獥鍙ｏ紙8涓寮忕獥鍙?2涓柊澧炰复鏃剁獥鍙ｏ級鈥?/p>

• keepAliveTime锛氬綋绾跨▼姹犵嚎绋嬫暟閲忚秴杩嘽orePoolSize鏃讹紝澶氫綑鐨勭┖闂茬嚎绋嬬殑瀛樻椿鏃堕棿銆傚嵆锛氳秴杩嘽orePoolSize鐨勭┖闂茬嚎绋嬶紝鍦ㄥ闀挎椂闂村唴锛屼細琚攢姣併€傛寚浠ｂ€滃ぇ鍫傜粡鐞嗗彂鐜版柊澧炵殑2涓复鏃剁獥鍙ｇ┖闂插悗锛屽張绛夊緟瑙傚療浜?0鍒嗛挓鈥濅腑鐨勬暟鍊?0

• unit锛歬eepAliveTime鐨勫崟浣嶏紱鎸囦唬鈥滀笂渚嬩腑鐨?0鍒嗛挓鈥濅腑鐨勫垎閽?br>

• workQueue锛氫换鍔￠槦鍒楋紝琚彁浜や絾灏氭湭琚墽琛岀殑浠诲姟锛涙寚浠ｂ€滀笂渚嬩腑鐨?0涓獥鍙ｂ€?/p>

• threadFactory锛氱嚎绋嬪伐鍘傦紝鐢ㄤ簬鍒涘缓绾跨▼锛屼竴鑸敤榛樿鐨勫嵆鍙紱鍚庣画浼氫笓棰樿璁?/p>

• handler锛氭嫆缁濈瓥鐣ャ€傚綋浠诲姟澶鏉ヤ笉鍙婂鐞嗭紝濡備綍鎷掔粷浠诲姟锛涘悗缁細涓撻璁ㄨ

  
  

01銆佽繘涓€姝ュ垎鏋?/strong>

閫氳繃涓婁緥鐨勫満鏅唬鍏ワ紝鎴戜滑鍐嶅绾跨▼姹犺繘琛屾繁鍏ュ垎鏋愩€?/p>

绾跨▼姹犱腑鏈変袱涓牳蹇冨弬鏁帮紝寰堝鏄撳紕閿欙紝鎴戜滑鍐嶈鲸鏋愪竴涓嬶細

• corePoolSize锛氳鍊艰瀹氬ソ浠ュ悗锛岄粯璁ゆ儏鍐典笅骞朵笉浼氬湪绾跨▼姹犱腑鍒涘缓浠讳綍绾跨▼锛岃€屾槸绛夊緟鏈変换鍔℃潵鏃舵墠寮€濮嬪垱寤虹嚎绋嬶紱鍙湁鏄惧紡璋冪敤浜唒restartAllCoreThreads鏂规硶鍚庯紝绾跨▼姹犳墠浼氶鍏堝垱寤篶orePoolSize涓嚎绋嬨€備篃灏辨槸璇达紝榛樿鎯呭喌涓嬪垱寤虹殑绾跨▼姹狅紝绾跨▼姹犱腑鐨勭嚎绋嬫暟涓?锛屽綋鏈変换鍔℃潵涔嬪悗锛屾墠浼氬垱寤轰互绾跨▼鍘绘墽琛屼换鍔★紝褰撶嚎绋嬫睜涓殑绾跨▼鏁扮洰杈惧埌corePoolSize鍚庯紝灏变細鎶婂埌杈剧殑浠诲姟鏀惧埌缂撳瓨闃熷垪褰撲腑銆?/p>

• maximumPoolSize锛氬畠琛ㄧず绾跨▼姹犱腑鏈€澶氳兘鍒涘缓澶氬皯涓嚎绋嬨€?/p>

• 杈惧埌锛坈orePoolSize+1锛夋暟鐩箣鍓嶇殑绾跨▼骞朵笉浼氳绾跨▼姹犻噴鏀鹃攢姣侊紝浣嗘槸浠庯紙corePoolSize+1锛墌 maximumPoolSize涔嬮棿鐨勫垱寤虹殑绾跨▼浼氳閲婃斁閿€姣併€?/p>

鏂囩珷鐨勬渶鍚庯紝鎴戜滑閫氳繃ThreadPoolExecutor鐨勬墽琛岃皟搴︾▼搴忔簮浠ｇ爜锛屽垎鏋愪竴涓嬪悜绾跨▼姹犳彁浜や綔涓氱殑鏃跺€欙紝鍒板簳鍙戠敓浜嗕粈涔堬紝瑙佷唬鐮?锛涘浘1璇存槑浜嗙嚎绋嬫睜鐨勬墽琛岃繃绋嬨€?/p>

2

public void execute(Runnable command) {
    if (command == null)
        throw new NullPointerException();
    int c = ctl.get();
    //鍒╃敤workerCountOf鑾峰彇褰撳墠绾跨▼姹犵殑绾跨▼鎬绘暟
    //濡傛灉灏忎簬corePoolSize锛岃皟鐢╝ddWorker璋冨害绾跨▼鎵ц
    if (workerCountOf(c) < corePoolSize) {
        if (addWorker(command, true))
            return;
        c = ctl.get();
    }
    //濡傛灉澶т簬corePoolSize锛屽垯璋冪敤workQueue.offer
    //灏嗕换鍔¤繘鍏ョ瓑寰呴槦鍒?/span>
    if (isRunning(c) && workQueue.offer(command)) {
        int recheck = ctl.get();
        if (! isRunning(recheck) && remove(command))
            reject(command);
        else if (workerCountOf(recheck) == 0)
            addWorker(null, false);
    }
    //濡傛灉杩涘叆绛夊緟闃熷垪澶辫触锛屽垯灏嗕换鍔℃彁浜ょ粰绾跨▼姹?/span>
    //濡傛灉绾跨▼姹犳暟鐩凡缁忚揪鍒癿aximumPoolSize锛屽垯鎵ц鎷掔粷绛栫暐
    else if (!addWorker(command, false))
        reject(command);
 }

鍥? 绾跨▼姹犳墽琛岃皟搴﹁繃绋?/p>

銆愬弬鑰冭祫鏂欍€?/span>

1 Java澶氱嚎绋嬬紪绋嬪疄鎴樻寚鍗楋紝 榛勬枃娴凤紝 涓浗宸ヤ俊鍑虹増闆嗗洟銆?/span>

2 瀹炴垬Java楂樺苟鍙戠▼搴忚璁★紝 钁涗竴楦ｏ紝閮秴锛?涓浗宸ヤ俊鍑虹増闆嗗洟锛岀數瀛愬伐涓氬嚭鐗堢ぞ銆?/span>

鏈夋晥鍦板埄鐢ㄦ偍鐨勭鐗囧寲鏃堕棿锛屾瘡鏃ョ簿杩涳紱鐙蹇紝浼楄杩滐紒鎯充簡瑙ｆ洿澶氳蒋浠跺紑鍙戞妧鏈笌浜虹敓鎰熸偀鍒嗕韩锛岃闀挎寜浜岀淮鐮佸浘鐗囷紝鍏虫敞绋嬪簭鍛榗hatbook銆傚鏋滆寰楁枃绔犳湁鐢紝鍚屾椂娆㈣繋骞舵劅璋㈡偍鑳芥妸鏂囩珷鍒嗕韩缁欐湁闇€瑕佺殑浼欎即锛屽ぇ瀹跺叡鍚岃繘姝ャ€?/p>

绋嬪簭鍛楥hatbook

          

绋嬪簭鍛橀兘鍏虫敞浜嗭紝鏉ヤ笉鍙婅В閲婏紝闀挎寜鍥剧墖锛屽揩涓婅溅

姣忔棩涓€鍙?/strong>

鏃╀笉璧疯兘璇竴澶╀簨锛屽皯涓嶅鑳借涓€鐢熶簨銆?/p>

鈥斺€旇挋鍙よ皻璇?/p>

鏈枃寤朵几闃呰

鐭ヨ瘑鐐?锛欽ava鍐呭瓨妯″瀷

鐭ヨ瘑鐐?锛氱紪鍐欓珮骞跺彂绋嬪簭鐨勨€滄纭Э鍔库€?/p>

鐭ヨ瘑鐐?锛氫粈涔堟槸绾跨▼姹?/p>

鐭ヨ瘑鐐?锛氬唴閮ㄧ被鐨勭被鍨嬨€佸疄鐜版柟寮忓強搴旂敤鍦烘櫙

鎺ㄨ崘1锛?/p>

鎺ㄨ崘2锛?/p>