{"id":3064,"date":"2023-08-28T10:09:55","date_gmt":"2023-08-28T02:09:55","guid":{"rendered":"https:\/\/xinchewhd.com.cn\/?p=3064"},"modified":"2023-08-28T10:09:55","modified_gmt":"2023-08-28T02:09:55","slug":"%e7%ba%bf%e7%a8%8b%e6%95%b0%e7%aa%81%e5%a2%9e%ef%bc%81%e9%a2%86%e5%af%bc%ef%bc%9a%e8%b0%81%e5%86%8d%e8%bf%99%e4%b9%88%e5%86%99%e5%b0%b1%e6%bb%9a%e8%9b%8b%ef%bc%81","status":"publish","type":"post","link":"https:\/\/xinchewhd.com.cn\/index.php\/java\/%e7%ba%bf%e7%a8%8b%e6%95%b0%e7%aa%81%e5%a2%9e%ef%bc%81%e9%a2%86%e5%af%bc%ef%bc%9a%e8%b0%81%e5%86%8d%e8%bf%99%e4%b9%88%e5%86%99%e5%b0%b1%e6%bb%9a%e8%9b%8b%ef%bc%81\/","title":{"rendered":"\u7ebf\u7a0b\u6570\u7a81\u589e\uff01\u9886\u5bfc\uff1a\u8c01\u518d\u8fd9\u4e48\u5199\u5c31\u6eda\u86cb\uff01"},"content":{"rendered":"
\n
<\/span><\/span><\/p>
\u60a8\u597d\uff0c\u6211\u662f\u8def\u4eba\uff0c\u66f4\u591a\u4f18\u8d28\u6587\u7ae0\u89c1\u4e2a\u4eba\u535a\u5ba2\uff1ahttp:\/\/itsoku.com<\/strong><\/span><\/strong><\/span><\/strong><\/p>
\n    
\n     
\n      
\n       <\/mp-common-profile>\n      <\/section><\/pre>\n<\/section>\n
<\/span><\/p>\n
<\/h3>\n
\u524d\u8a00<\/span><\/strong><\/h3>\n
<\/h3>\n
\u4eca\u5929\u7ed9\u5927\u5bb6\u5206\u4eab\u4e00\u4e2a\u7ebf\u4e0a\u95ee\u9898\u5f15\u51fa\u7684\u4e00\u6b21\u601d\u8003\uff0c\u8fc7\u7a0b\u6bd4\u8f83\u957f\uff0c\u4f46\u662f\u633a\u6709\u610f\u601d\u3002<\/span><\/h3>\n
\u4eca\u5929\u4e0a\u73ed\u628a\u9700\u6c42\u5199\u5b8c\uff0c\u51fa\u4e8e\u5b66\u4e60\uff08\u6478\u9c7c\uff09\u7684\u5fc3\u7406\u4e0askywalking\u770b\u770b\uff0c\u7a81\u7136\u53d1\u73b0\u6211\u4eec\u7684\u4e00\u4e2a\u5e94\u7528\uff0c\u5e94\u7528\u5185\u7ebf\u7a0b\u6570\u8d85\u8fc7900\u6761\uff0c\u63a5\u8fd11000\u6761\uff0c\u4f46\u662fcpu\u5e76\u6ca1\u6709\u9ad8\u6da8\uff0c\u5185\u5b58\u4e5f\u4e0d\u7b97\u9ad8\u5cf0\u3002<\/span><\/p>\n
\u4f46\u662f\u654f\u9510\u7684\u6211\u8fd8\u662f\u7acb\u523b\u610f\u8bc6\u5230\u8fd9\u4e2a\u5e94\u7528\u6709\u4e0d\u59a5\uff0c\u56e0\u4e3a\u7ebf\u7a0b\u6570\u592a\u591a\u4e86\uff0c\u4e0d\u7b26\u5408\u6211\u4eec\u4e00\u4e2a\u6b63\u5e38\u5065\u5eb7\u7684\u5e94\u7528\u6570\u91cf\u3002\u719f\u7ec3\u7684\u6253\u51facpu dump\u89c2\u5bdf\uff0c\u9996\u5148\u770b\u7ebf\u7a0b\u7ec4\u540d\u7684\u6982\u89c8\u3002<\/span><\/p>\n
\u4ece\u7ebf\u7a0b\u5206\u7ec4\u770b\uff0cpool\u540d\u5f00\u5934\u7ebf\u7a0b\u5360616\u6761\uff0c\u800c\u4e14waiting\u72b6\u6001\u4e5f\u662f616\u6761\uff0c\u8fd9\u4e2a\u70b9\u5c31\u975e\u5e38\u53ef\u7591\u4e86\uff0c\u6211\u65ad\u5b9a\u5c31\u662f\u8fd9\u4e2apool\u5f00\u5934\u7ebf\u7a0b\u6c60\u5bfc\u81f4\u7684\u95ee\u9898\u3002\u6211\u4eec\u5148\u6392\u67e5\u4e3a\u4f55\u8fd9\u4e2a\u7ebf\u7a0b\u6c60\u4e2d\u4f1a\u6709600+\u7684\u7ebf\u7a0b\u5904\u4e8ewaiting\u72b6\u6001\u5e76\u4e14\u65e0\u6cd5\u91ca\u653e\uff0c\u8bb0\u63a5\u4e0b\u6765\u6211\u4eec\u627e\u51e0\u6761\u7ebf\u7a0b\u7684\u5806\u6808\u89c2\u5bdf\u5177\u4f53\u5806\u6808\uff1a<\/span><\/p>\n
\u8fd9\u4e2a\u5806\u6808\u770b\u4e0a\u53bb\u5f88\u5408\u7406\uff0c\u7ebf\u7a0b\u5728\u7ebf\u7a0b\u6c60\u4e2d\u4e0d\u65ad\u7684\u5faa\u73af\u83b7\u53d6\u4efb\u52a1\uff0c\u56e0\u4e3a\u83b7\u53d6\u4e0d\u5230\u4efb\u52a1\u6240\u4ee5\u8fdb\u5165\u4e86waiting\u72b6\u6001\uff0c\u7b49\u5f85\u7740\u6709\u4efb\u52a1\u540e\u88ab\u5524\u9192\u3002<\/span><\/p>\n
\u770b\u4e0a\u53bb\u4e0d\u53ea\u4e00\u4e2a\u7ebf\u7a0b\u6c60\uff0c\u5e76\u4e14\u8fd9\u4e9b\u7ebf\u7a0b\u6c60\u7684\u540d\u5b57\u5c45\u7136\u662f\u4e00\u6837\u7684\uff0c\u6211\u5927\u80c6\u7684\u731c\u6d4b\u4e00\u4e0b\uff0c\u662f\u4e0d\u65ad\u7684\u521b\u5efa\u540c\u6837\u7684\u7ebf\u7a0b\u6c60\uff0c\u4f46\u662f\u7ebf\u7a0b\u6c60\u65e0\u6cd5\u88ab\u56de\u6536\u5bfc\u81f4\u7684\u7ebf\u7a0b\u6570\uff0c\u6240\u4ee5\u63a5\u4e0b\u6765\u6211\u4eec\u8981\u5206\u6790\u4e24\u4e2a\u95ee\u9898\uff0c\u9996\u5148\u8fd9\u4e2a\u7ebf\u7a0b\u6c60\u5728\u4ee3\u7801\u91cc\u662f\u54ea\u4e2a\u7ebf\u7a0b\u6c60\uff0c\u7b2c\u4e8c\u8fd9\u4e2a\u7ebf\u7a0b\u6c60\u662f\u600e\u4e48\u88ab\u521b\u5efa\u7684\uff1f\u4e3a\u5565\u91ca\u653e\u4e0d\u4e86\uff1f<\/span><\/p>\n
\u6211\u5728idea\u641c\u7d22<\/span>new ThreadPoolExecutor()<\/span><\/code>\u5f97\u5230\u7684\u7ed3\u679c\u662f\u8fd9\u6837\u7684\uff1a<\/span><\/p>\n
\u4e8e\u662f\u6211\u9677\u5165\u61f5\u903c\u7684\u72b6\u6001\uff0c\u96be\u9053\u8fd8\u6709\u5176\u4ed6\u9a9a\u64cd\u4f5c\uff1f<\/span><\/p>\n
\u6b63\u5728\u8fd9\u65f6\uff0c\u4e00\u4f4d\u4e0d\u77e5\u540d\u7684\u90d1\u7f51\u53cb\u53d1\u6765\u4e00\u5f20\u622a\u56fe\uff1a<\/span><\/p>\n
\u597d\u5bb6\u4f19\uff01\u7adf\u7136\u662f\u7528<\/span>new FixedTreadPool()<\/span><\/code>\u6574\u51fa\u6765\u7684\u3002\u96be\u602a\u6211\u5b8c\u5168\u641c\u4e0d\u5230\uff0c\u56e0\u4e3a\u7528\u7684<\/span>new FixedTreadPool()<\/span><\/code>\uff0c\u6240\u4ee5\u7ebf\u7a0b\u6c60\u4e2d\u7684\u7ebf\u7a0b\u540d\u662f\u9ed8\u8ba4\u7684pool\uff08\u53c8\u591a\u4e86\u4e00\u4e2a\u4e0d\u4f7f\u7528Executors\u6765\u521b\u5efa\u7ebf\u7a0b\u6c60\u7684\u7406\u7531\uff09\u3002<\/span><\/p>\n
\u7136\u540e\u6211\u8feb\u4e0d\u53cadie\u7684\u6253\u5f00\u4ee3\u7801\uff0c\u8bd5\u56fe\u627e\u5230\u7f6a\u9b41\u7978\u9996\uff0c\u7ed3\u679c\u53d1\u73b0\u4f5c\u8005\u5c45\u7136\u662f\u6211\u81ea\u5df1\u3002\u8fd9\u662f\u53e6\u4e00\u4e2a\u60ca\u559c\uff0c\u60ca\u5413\u7684\u60ca\u3002<\/span><\/p>\n
\u51b7\u9759\u4e0b\u6765\u540e\u6211\u68b3\u7406\u4e00\u904d\u4ee3\u7801\uff0c\u8fd9\u4e2a\u63a5\u53e3\u662f\u6211\u4e24\u5e74\u524d\u5199\u7684\uff0c\u4e3b\u8981\u662f\u529f\u80fd\u662f\u7edf\u8ba1\u7528\u6237\u7684\u94b1\u5305\u6bcf\u4e2a\u6708\u7684\u6d41\u6c34\uff0c\u56e0\u4e3a\u62c5\u5fc3\u7edf\u8ba1\u6bd4\u8f83\u6162\uff0c\u6240\u4ee5\u4f7f\u7528\u4e86\u7ebf\u7a0b\u6c60\uff0c\u505a\u4e86\u6279\u91cf\u7684\u5904\u7406\uff0c\u6ca1\u60f3\u5230\u5c45\u7136\u5bfc\u81f4\u4e86\u7ebf\u7a0b\u6570\u8fc7\u9ad8\uff0c\u867d\u7136\u6ca1\u6709\u5bfc\u81f4\u4e8b\u6545\uff0c\u4f46\u662f\u786e\u5b9e\u662f\u6f5c\u5728\u7684\u9690\u60a3\uff0c\u73b0\u5728\u6ca1\u51fa\u4e8b\u4e0d\u4ee3\u8868\u4ee5\u540e\u4e0d\u4f1a\u51fa\u4e8b\u3002<\/span><\/p>\n
\u53bb\u6389\u591a\u4f59\u4e1a\u52a1\u903b\u8f91\uff0c\u6211\u7b80\u5355\u7684\u8fd8\u539f\u4e00\u4e2a\u4ee3\u7801\u7ed9\u5927\u5bb6\u770b\uff0c\u8fd8\u539f\u73b0\u573a\uff1a<\/span><\/p>\n
private<\/span> static<\/span> void<\/span> threadDontGcDemo<\/span>()<\/span><\/span>{
        ExecutorService executorService = Executors.newFixedThreadPool(10<\/span>);
        executorService.submit(() -> {
            System.out.println(\"111\"<\/span>);
        });
    }
<\/code><\/pre>\n
<\/h3>\n
\u90a3\u4e48\u4e3a\u5565\u7ebf\u7a0b\u6c60\u91cc\u9762\u7684\u7ebf\u7a0b\u548c\u7ebf\u7a0b\u6c60\u90fd\u6ca1\u91ca\u653e\u5462\u3002<\/span><\/strong><\/h3>\n
<\/h3>\n
\u96be\u9053\u662f\u56e0\u4e3a\u6ca1\u6709\u8c03\u7528shutdown\uff1f\u6211\u5927\u6982\u80fd\u7406\u89e3\u6211\u4e24\u5e74\u524d\u5f53\u65f6\u4e3a\u5565\u4e0d\u8c03\u7528shutdown\uff0c\u662f\u56e0\u4e3a\u5f53\u521d\u6211\u89c9\u5f97\u63a5\u53e3\u8dd1\u5b8c\uff0c\u65b9\u6cd5\u8d70\u5230\u7ed3\u675f\uff0c\u7406\u8bba\u4e0a\u6808\u5e27\u51fa\u6808\uff0c\u5c40\u90e8\u53d8\u91cf\u5e94\u8be5\u90fd\u9500\u6bc1\u4e86\uff0c\u6309\u7406\u8bf4<\/span><\/span>executorService<\/span><\/code>\u8fd9\u4e2a\u53d8\u91cf\u5e94\u8be5\u76f4\u63a5GG\u4e86\uff0c\u90a3\u4e48\u6309\u7406\u8bf4\u6211\u662f\u4e0d\u7528\u8c03\u7528shutdown\u65b9\u6cd5\u7684\u3002<\/span><\/h3>\n
\u6211\u7b80\u5355\u7684\u8dd1\u4e86\u4e2ademo\uff0c\u5faa\u73af\u7684\u53bbnew\u7ebf\u7a0b\u6c60\uff0c\u4e0d\u8c03\u7528shutdown\u65b9\u6cd5\uff0c\u770b\u770b\u7ebf\u7a0b\u6c60\u80fd\u4e0d\u80fd\u88ab\u56de\u6536<\/span><\/p>\n
\u6253\u5f00<\/span>java visual vm<\/span><\/code>\u67e5\u770b\u5b9e\u65f6\u7ebf\u7a0b\uff1a<\/span><\/p>\n
\u53ef\u4ee5\u770b\u5230\u7ebf\u7a0b\u6570\u548c\u7ebf\u7a0b\u6c60\u90fd\u4e00\u76f4\u5728\u589e\u52a0\uff0c\u4f46\u662f\u4e00\u76f4\u6ca1\u6709\u88ab\u56de\u6536\uff0c\u786e\u5b9e\u7b26\u5408\u53d1\u751f\u7684\u95ee\u9898\u72b6\u51b5\uff0c\u90a3\u4e48\u5047\u5982\u6211\u5728\u65b9\u6cd5\u7ed3\u675f\u524d\u8c03\u7528shutdown\u65b9\u6cd5\u5462\uff0c\u4f1a\u4e0d\u4f1a\u56de\u6536\u7ebf\u7a0b\u6c60\u548c\u7ebf\u7a0b\u5462\uff1f<\/span><\/p>\n
\u7b80\u5355\u5199\u4e2ademo\u7ed3\u5408jvisualvm\u9a8c\u8bc1\u4e0b\uff1a<\/span><\/p>\n
\u7ed3\u679c\u662f\u7ebf\u7a0b\u548c\u7ebf\u7a0b\u6c60\u90fd\u88ab\u56de\u6536\u4e86\u3002\u4e5f\u5c31\u662f\u8bf4\uff0c\u6267\u884c\u4e86shutdown\u7684\u7ebf\u7a0b\u6c60\u6700\u540e\u4f1a\u56de\u6536\u7ebf\u7a0b\u6c60\u548c\u7ebf\u7a0b\u5bf9\u8c61\u3002<\/strong><\/span><\/p>\n
\u6211\u4eec\u77e5\u9053\uff0c\u4e00\u4e2a\u5bf9\u8c61\u80fd\u4e0d\u80fd\u56de\u6536\uff0c\u662f\u770b\u5b83\u5230gc root\u4e4b\u95f4\u6709\u6ca1\u6709\u53ef\u8fbe\u8def\u5f84\uff0c\u7ebf\u7a0b\u6c60\u4e0d\u80fd\u56de\u6536\u8bf4\u660e\u5230\u8fbe\u7ebf\u7a0b\u6c60\u7684gc root\u8fd8\u662f\u6709\u53ef\u8fbe\u8def\u5f84\u7684\u3002\u8fd9\u91cc\u8bb2\u4e2a\u51b7\u77e5\u8bc6\uff0c\u8fd9\u91cc\u7684\u7ebf\u7a0b\u6c60\u7684gc root\u662f\u7ebf\u7a0b\uff0c\u5177\u4f53\u7684gc\u8def\u5f84\u662f<\/span>thread->workers->\u7ebf\u7a0b\u6c60<\/span><\/code>\u3002<\/span><\/p>\n
\u7ebf\u7a0b\u5bf9\u8c61\u662f\u7ebf\u7a0b\u6c60\u7684gc root\uff0c\u5047\u5982\u7ebf\u7a0b\u5bf9\u8c61\u80fd\u88abgc\uff0c\u90a3\u4e48\u7ebf\u7a0b\u6c60\u5bf9\u8c61\u80af\u5b9a\u4e5f\u80fd\u88abgc\u6389\uff08\u56e0\u4e3a\u7ebf\u7a0b\u6c60\u5bf9\u8c61\u5df2\u7ecf\u6ca1\u6709\u5230gc root\u7684\u53ef\u8fbe\u8def\u5f84\u4e86\uff09\u3002<\/span><\/p>\n
<\/p>\n
\u90a3\u4e48\u73b0\u5728\u95ee\u9898\u5c31\u8f6c\u4e3a\u7ebf\u7a0b\u5bf9\u8c61\u662f\u5728\u4ec0\u4e48\u65f6\u5019gc\u3002<\/span><\/strong><\/p>\n
\u90d1\u7f51\u53cb\u7ed9\u4e86\u4e00\u4e2a\u7c97\u6d45\u4f46\u662f\u5408\u7406\u7684\u89e3\u91ca\uff0c\u7ebf\u7a0b\u5bf9\u8c61\u80af\u5b9a\u4e0d\u662f\u5728\u8fd0\u884c\u4e2d\u7684\u65f6\u5019\u88ab\u56de\u6536\u7684\uff0c\u56e0\u4e3ajvm\u80af\u5b9a\u4e0d\u53ef\u80fd\u53bb\u56de\u6536\u4e00\u6761\u5728\u8fd0\u884c\u4e2d\u7684\u7ebf\u7a0b\uff0c\u81f3\u5c11runnalbe\u72b6\u6001\u7684\u7ebf\u7a0bjvm\u4e0d\u53ef\u80fd\u53bb\u56de\u6536\u3002<\/span><\/p>\n
\u5728stackoverflow\u4e0a\u6211\u627e\u5230\u4e86\u66f4\u51c6\u786e\u7684\u7b54\u6848\uff1a<\/span><\/p>\n
\n
A running thread is considered a so called garbage collection root and is one of those things keeping stuff from being garbage collected\u3002<\/span><\/p>\n<\/blockquote>\n
\u8fd9\u53e5\u8bdd\u7684\u610f\u601d\u662f\uff0c\u4e00\u6761\u6b63\u5728\u8fd0\u884c\u7684\u7ebf\u7a0b\u662fgc root\uff0c\u6ce8\u610f\uff0c\u662f\u6b63\u5728\u8fd0\u884c\uff0c\u8fd9\u4e2a\u6b63\u5728\u8fd0\u884c\u6211\u5148\u900f\u9732\u4e0b\uff0c\u5373\u4f7f\u662fwaiting\u72b6\u6001\uff0c\u4e5f\u7b97\u6b63\u5728\u8fd0\u884c\u3002\u8fd9\u4e2a\u56de\u7b54\u7684\u6574\u4f53\u7684\u610f\u601d\u662f\uff0c\u8fd0\u884c\u7684\u7ebf\u7a0b\u662fgc root\uff0c\u4f46\u662f\u975e\u8fd0\u884c\u7684\u7ebf\u7a0b\u4e0d\u662fgc root\uff08\u53ef\u4ee5\u88ab\u56de\u6536\uff09\u3002<\/span><\/p>\n
\u73b0\u5728\u6bd4\u8f83\u6e05\u695a\u4e86\uff0c\u7ebf\u7a0b\u6c60\u548c\u7ebf\u7a0b\u88ab\u56de\u6536\u7684\u5173\u952e\u5c31\u5728\u4e8e\u7ebf\u7a0b\u80fd\u4e0d\u80fd\u88ab\u56de\u6536\uff0c\u90a3\u4e48\u56de\u5230\u539f\u6765\u7684\u8d77\u70b9\uff0c\u4e3a\u4f55\u8c03\u7528\u7ebf\u7a0b\u6c60\u7684shutdown\u65b9\u6cd5\u80fd\u591f\u5bfc\u81f4\u7ebf\u7a0b\u548c\u7ebf\u7a0b\u6c60\u88ab\u56de\u6536\u5462\uff1f\u96be\u9053\u662fshutdown\u65b9\u6cd5\u628a\u7ebf\u7a0b\u53d8\u6210\u4e86\u975e\u8fd0\u884c\u72b6\u6001\u5417\uff1f<\/span><\/p>\n
\n
talk is cheap,show me the code<\/p>\n<\/blockquote>\n
\u6211\u4eec\u76f4\u63a5\u770b\u770b\u7ebf\u7a0b\u6c60\u7684shutdown\u65b9\u6cd5\u7684\u6e90\u7801<\/span><\/p>\n
public<\/span> void<\/span> shutdown<\/span>()<\/span> <\/span>{
        final<\/span> ReentrantLock mainLock = this<\/span>.mainLock;
        mainLock.lock();
        try<\/span> {
            checkShutdownAccess();
            advanceRunState(SHUTDOWN);
            interruptIdleWorkers();
            onShutdown(); \/\/ hook for ScheduledThreadPoolExecutor<\/span>
        } finally<\/span> {
            mainLock.unlock();
        }
        tryTerminate();
}

private<\/span> void<\/span> interruptIdleWorkers<\/span>()<\/span> <\/span>{
        interruptIdleWorkers(false<\/span>);
}

private<\/span> void<\/span> interruptIdleWorkers<\/span>(boolean<\/span> onlyOne)<\/span> <\/span>{
        final<\/span> ReentrantLock mainLock = this<\/span>.mainLock;
        mainLock.lock();
        try<\/span> {
            for<\/span> (Worker w : workers) {
                Thread t = w.thread;
                if<\/span> (!t.isInterrupted() && w.tryLock()) {
                    try<\/span> {
                        t.interrupt();
                    } catch<\/span> (SecurityException ignore) {
                    } finally<\/span> {
                        w.unlock();
                    }
                }
                if<\/span> (onlyOne)
                    break<\/span>;
            }
        } finally<\/span> {
            mainLock.unlock();
        }
}
<\/code><\/pre>\n
\u6211\u4eec\u4ece<\/span>interruptIdleWorkers<\/span><\/code>\u65b9\u6cd5\u5165\u624b\uff0c\u8fd9\u65b9\u6cd5\u770b\u4e0a\u53bb\u6700\u53ef\u7591\uff0c\u770b\u5230<\/span>interruptIdleWorkers<\/span><\/code>\u65b9\u6cd5\uff0c\u8fd9\u4e2a\u65b9\u6cd5\u91cc\u9762\u4e3b\u8981\u5c31\u505a\u4e86\u4e00\u4ef6\u4e8b\uff0c\u904d\u5386\u5f53\u524d\u7ebf\u7a0b\u6c60\u4e2d\u7684\u7ebf\u7a0b\uff0c\u5e76\u4e14\u8c03\u7528\u7ebf\u7a0b\u7684<\/span>interrupt()<\/span><\/code>\u65b9\u6cd5\uff0c\u901a\u77e5\u7ebf\u7a0b\u4e2d\u65ad\uff0c\u4e5f\u5c31\u662f\u8bf4shutdown\u65b9\u6cd5\u53ea\u662f\u53bb\u904d\u5386\u6240\u6709\u7ebf\u7a0b\u6c60\u4e2d\u7684\u7ebf\u7a0b\uff0c\u7136\u540e\u901a\u77e5\u7ebf\u7a0b\u4e2d\u65ad\u3002\u6240\u4ee5\u6211\u4eec\u9700\u8981\u4e86\u89e3\u7ebf\u7a0b\u6c60\u91cc\u7684\u7ebf\u7a0b\u662f\u600e\u4e48\u5904\u7406\u4e2d\u65ad\u7684\u901a\u77e5\u7684\u3002<\/span><\/p>\n
\u6211\u4eec\u70b9\u5f00worker\u5bf9\u8c61\uff0c\u8fd9\u4e2aworker\u5bf9\u8c61\u662f\u7ebf\u7a0b\u6c60\u4e2d\u5b9e\u9645\u8fd0\u884c\u7684\u7ebf\u7a0b\uff0c\u6240\u4ee5\u6211\u4eec\u76f4\u63a5\u770bworker\u7684run\u65b9\u6cd5\uff0c\u4e2d\u65ad\u901a\u77e5\u80af\u5b9a\u662f\u5728\u91cc\u9762\u88ab\u5904\u7406\u4e86<\/span><\/p>\n
\/\/WOrker\u7684run\u65b9\u6cd5\u91cc\u9762\u76f4\u63a5\u8c03\u7528\u7684\u662f\u8fd9\u4e2a\u65b9\u6cd5<\/span>
final<\/span> void<\/span> runWorker<\/span>(Worker w)<\/span> <\/span>{
        Thread wt = Thread.currentThread();
        Runnable task = w.firstTask;
        w.firstTask = null<\/span>;
        w.unlock(); \/\/ allow interrupts<\/span>
        boolean<\/span> completedAbruptly = true<\/span>;
        try<\/span> {
            while<\/span> (task != null<\/span> || (task = getTask()) != null<\/span>) {
                w.lock();
                \/\/ If pool is stopping, ensure thread is interrupted;<\/span>
                \/\/ if not, ensure thread is not interrupted.  This<\/span>
                \/\/ requires a recheck in second case to deal with<\/span>
                \/\/ shutdownNow race while clearing interrupt<\/span>
                if<\/span> ((runStateAtLeast(ctl.get(), STOP) ||
                     (Thread.interrupted() &&
                      runStateAtLeast(ctl.get(), STOP))) &&
                    !wt.isInterrupted())
                    wt.interrupt();
                try<\/span> {
                    beforeExecute(wt, task);
                    Throwable thrown = null<\/span>;
                    try<\/span> {
                        task.run();
                    } catch<\/span> (RuntimeException x) {
                        thrown = x; throw<\/span> x;
                    } catch<\/span> (Error x) {
                        thrown = x; throw<\/span> x;
                    } catch<\/span> (Throwable x) {
                        thrown = x; throw<\/span> new<\/span> Error(x);
                    } finally<\/span> {
                        afterExecute(task, thrown);
                    }
                } finally<\/span> {
                    task = null<\/span>;
                    w.completedTasks++;
                    w.unlock();
                }
            }
            completedAbruptly = false<\/span>;
        } finally<\/span> {
            processWorkerExit(w, completedAbruptly);
        }
}
<\/code><\/pre>\n
\u8fd9\u4e2arunwoker\u5c5e\u4e8e\u662f\u7ebf\u7a0b\u6c60\u7684\u6838\u5fc3\u65b9\u6cd5\u4e86\uff0c\u76f8\u5f53\u7684\u6709\u610f\u601d\uff0c\u7ebf\u7a0b\u6c60\u80fd\u4e0d\u65ad\u8fd0\u4f5c\u7684\u539f\u7406\u5c31\u662f\u8fd9\u91cc\uff0c\u6211\u4eec\u4e00\u70b9\u70b9\u770b\u3002<\/span><\/p>\n
\u9996\u5148\u6700\u5916\u5c42\u7528\u4e00\u4e2awhile\u5faa\u73af\u5957\u4f4f\uff0c\u7136\u540e\u4e0d\u65ad\u7684\u8c03\u7528<\/span>gettask()<\/span><\/code>\u65b9\u6cd5\u4e0d\u65ad\u4ece\u961f\u5217\u4e2d\u53d6\u4efb\u52a1\uff0c\u5047\u5982\u62ff\u4e0d\u5230\u4efb\u52a1\u6216\u8005\u4efb\u52a1\u6267\u884c\u53d1\u751f\u5f02\u5e38\uff08\u629b\u51fa\u5f02\u5e38\u4e86\uff09\u90a3\u5c31\u5c5e\u4e8e\u5f02\u5e38\u60c5\u51b5\uff0c\u76f4\u63a5\u5c06<\/span>completedAbruptly<\/span><\/code> \u8bbe\u7f6e\u4e3atrue\uff0c\u5e76\u4e14\u8fdb\u5165\u5f02\u5e38\u7684<\/span>processWorkerExit<\/span><\/code>\u6d41\u7a0b\u3002<\/span><\/p>\n
\u6211\u4eec\u770b\u770b<\/span>gettask()<\/span><\/code>\u65b9\u6cd5\uff0c\u4e86\u89e3\u4e0b\u5565\u65f6\u5019\u53ef\u80fd\u4f1a\u629b\u51fa\u5f02\u5e38\uff1a<\/span><\/p>\n
private<\/span> Runnable getTask<\/span>()<\/span> <\/span>{
        boolean<\/span> timedOut = false<\/span>; \/\/ Did the last poll() time out?<\/span>

        for<\/span> (;;) {
            int<\/span> c = ctl.get();
            int<\/span> rs = runStateOf(c);

            \/\/ Check if queue empty only if necessary.<\/span>
            if<\/span> (rs >= SHUTDOWN && (rs >= STOP || workQueue.isEmpty())) {
                decrementWorkerCount();
                return<\/span> null<\/span>;
            }

            int<\/span> wc = workerCountOf(c);

            \/\/ Are workers subject to culling?<\/span>
            boolean<\/span> timed = allowCoreThreadTimeOut || wc > corePoolSize;

            if<\/span> ((wc > maximumPoolSize || (timed && timedOut))
                && (wc > 1<\/span> || workQueue.isEmpty())) {
                if<\/span> (compareAndDecrementWorkerCount(c))
                    return<\/span> null<\/span>;
                continue<\/span>;
            }

            try<\/span> {
                Runnable r = timed ?
                    workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :
                    workQueue.take();
                if<\/span> (r != null<\/span>)
                    return<\/span> r;
                timedOut = true<\/span>;
            } catch<\/span> (InterruptedException retry) {
                timedOut = false<\/span>;
            }
        }
    }
<\/code><\/pre>\n
\u8fd9\u6837\u5f88\u6e05\u695a\u4e86\uff0c\u629b\u53bb\u524d\u9762\u7684\u5927\u90e8\u5206\u4ee3\u7801\u4e0d\u770b\uff0c\u8fd9\u53e5\u4ee3\u7801\u89e3\u91ca\u4e86gettask\u7684\u4f5c\u7528\uff1a<\/span><\/p>\n
Runnable r = timed ?
    workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :
    workQueue.take()
<\/code><\/pre>\n
gettask\u5c31\u662f\u4ece\u5de5\u4f5c\u961f\u5217\u4e2d\u53d6\u4efb\u52a1\uff0c\u4f46\u662f\u524d\u9762\u8fd8\u6709\u4e2atimed\uff0c\u8fd9\u4e2atimed\u7684\u8bed\u4e49\u662f\u8fd9\u6837\u7684\uff1a\u5982\u679c<\/span>allowCoreThreadTimeOut<\/span><\/code>\u53c2\u6570\u4e3atrue\uff08\u4e00\u822c\u4e3afalse\uff09\u6216\u8005\u5f53\u524d\u5de5\u4f5c\u7ebf\u7a0b\u6570\u8d85\u8fc7\u6838\u5fc3\u7ebf\u7a0b\u6570\uff0c\u90a3\u4e48\u4f7f\u7528\u961f\u5217\u7684poll\u65b9\u6cd5\u53d6\u4efb\u52a1\uff0c\u53cd\u4e4b\u4f7f\u7528take\u65b9\u6cd5\u3002<\/span><\/p>\n
\u8fd9\u4e24\u4e2a\u65b9\u6cd5\u4e0d\u662f\u91cd\u70b9\uff0c\u91cd\u70b9\u662fpoll\u65b9\u6cd5\u548ctake\u65b9\u6cd5\u90fd\u4f1a\u8ba9\u5f53\u524d\u7ebf\u7a0b\u8fdb\u5165<\/span>time_waiting<\/span><\/code>\u6216\u8005waiting\u72b6\u6001\u3002\u800c\u5f53\u7ebf\u7a0b\u5904\u4e8e\u5728\u7b49\u5f85\u72b6\u6001\u7684\u65f6\u5019\uff0c\u6211\u4eec\u8c03\u7528\u7ebf\u7a0b\u7684interrupt\u65b9\u6cd5\uff0c\u6beb\u65e0\u7591\u95ee\u4f1a\u4f7f\u7ebf\u7a0b\u5f53\u573a\u629b\u51fa\u5f02\u5e38\uff01<\/span><\/p>\n
\u4e5f\u5c31\u662f\u8bf4\u7ebf\u7a0b\u6c60\u7684<\/strong>shutdownnow<\/code>\u65b9\u6cd5\u8c03\u7528interruptIdleWorkers<\/code>\u53bb\u5bf9\u7ebf\u7a0b\u5bf9\u8c61interrupt\u662f\u4e3a\u4e86\u8ba9\u5904\u4e8ewaiting\u6216\u8005\u662ftime_waiting<\/code>\u7684\u7ebf\u7a0b\u629b\u51fa\u5f02\u5e38\u3002<\/strong><\/span><\/p>\n
\u90a3\u4e48\u7ebf\u7a0b\u6c60\u662f\u5728\u54ea\u91cc\u5904\u7406\u8fd9\u4e2a\u5f02\u5e38\u7684\u5462\uff1f\u6211\u4eec\u770b<\/span>runwoker<\/span><\/code>\u4e2d\u7684\u8c03\u7528\u7684<\/span>processWorkerExit<\/span><\/code>\u65b9\u6cd5\uff0c\u8bf4\u5b9e\u8bdd\u8fd9\u4e2a\u65b9\u6cd5\u770b\u7740\u5c31\u50cf\u5904\u7406\u629b\u51fa\u5f02\u5e38\u7684\u65b9\u6cd5\uff1a<\/span><\/p>\n
private<\/span> void<\/span> processWorkerExit<\/span>(Worker w, boolean<\/span> completedAbruptly)<\/span> <\/span>{
        if<\/span> (completedAbruptly) \/\/ If abrupt, then workerCount wasn't adjusted<\/span>
            decrementWorkerCount();

        final<\/span> ReentrantLock mainLock = this<\/span>.mainLock;
        mainLock.lock();
        try<\/span> {
            completedTaskCount += w.completedTasks;
            workers.remove(w);
        } finally<\/span> {
            mainLock.unlock();
        }

        tryTerminate();

        int<\/span> c = ctl.get();
        if<\/span> (runStateLessThan(c, STOP)) {
            if<\/span> (!completedAbruptly) {
                int<\/span> min = allowCoreThreadTimeOut ? 0<\/span> : corePoolSize;
                if<\/span> (min == 0<\/span> && ! workQueue.isEmpty())
                    min = 1<\/span>;
                if<\/span> (workerCountOf(c) >= min)
                    return<\/span>; \/\/ replacement not needed<\/span>
            }
            addWorker(null<\/span>, false<\/span>);
        }
}
<\/code><\/pre>\n
\u6211\u4eec\u53ef\u4ee5\u770b\u5230\uff0c\u5728\u8fd9\u4e2a\u65b9\u6cd5\u91cc\u6709\u4e00\u4e2a\u5f88\u660e\u663e\u7684 <\/span>workers.remove(w)<\/span><\/code>\u65b9\u6cd5\uff0c\u4e5f\u5c31\u662f\u5728\u8fd9\u91cc\uff0c\u8fd9\u4e2aw\u7684\u53d8\u91cf\uff0c\u88ab\u79fb\u51fa\u4e86workers\u8fd9\u4e2a\u96c6\u5408\uff0c\u5bfc\u81f4worker\u5bf9\u8c61\u4e0d\u80fd\u5230\u8fbegc root\uff0c\u4e8e\u662fworkder\u5bf9\u8c61\u987a\u7406\u6210\u7ae0\u7684\u53d8\u6210\u4e86\u4e00\u4e2a\u5783\u573e\u5bf9\u8c61\uff0c\u88ab\u56de\u6536\u6389\u4e86\u3002<\/span><\/p>\n
\u7136\u540e\u7b49\u5230worker\u4e2d\u6240\u6709\u7684worker\u90fd\u88ab\u79fb\u51faworks\u540e\uff0c\u5e76\u4e14\u5f53\u524d\u8bf7\u6c42\u7ebf\u7a0b\u4e5f\u5b8c\u6210\u540e\uff0c\u7ebf\u7a0b\u6c60\u5bf9\u8c61\u4e5f\u6210\u4e3a\u4e86\u4e00\u4e2a\u5b64\u513f\u5bf9\u8c61\uff0c\u6ca1\u529e\u6cd5\u5230\u8fbe<\/span>gc root<\/span><\/code>\uff0c\u4e8e\u662f\u7ebf\u7a0b\u6c60\u5bf9\u8c61\u4e5f\u88abgc\u6389\u4e86\u3002\u5199\u4e86\u633a\u957f\u7684\u7bc7\u5e45\uff0c\u6211\u5c0f\u7ed3\u4e00\u4e0b\uff1a<\/span><\/p>\n