您好,登錄后才能下訂單哦!
今天就跟大家聊聊有關(guān)Java中怎么設(shè)置線程池的大小,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。
這個說法到底是不是正確的呢?
其實這是極不正確的。那為什么呢?
首先我們從反面來看,假設(shè)這個說法是成立的,那我們在一臺服務(wù)器上部署多少個服務(wù)都無所謂了。因為線程池的大小只能服務(wù)器的核數(shù)有關(guān),所以這個說法是不正確的。那具體應(yīng)該怎么設(shè)置大小呢?
假設(shè)這個應(yīng)用是兩者混合型的,其中任務(wù)即有 CPU 密集,也有 IO 密集型的,那么我們改怎么設(shè)置呢?是不是只能拋硬盤來決定呢?
那么我們到底該怎么設(shè)置線程池大小呢?有沒有一些具體實踐方法來指導(dǎo)大家落地呢?讓我們來深入地了解一下。
Little's Law(利特爾法則)
一個系統(tǒng)請求數(shù)等于請求的到達率與平均每個單獨請求花費的時間之乘積
假設(shè)服務(wù)器單核的,對應(yīng)業(yè)務(wù)需要保證請求量(QPS):10 ,真正處理一個請求需要 1 秒,那么服務(wù)器每個時刻都有 10 個請求在處理,即需要 10 個線程
同樣,我們可以使用利特爾法則(Little's law)來判定線程池大小。我們只需計算請求到達率和請求處理的平均時間。然后,將上述值放到利特爾法則(Little's law)就可以算出系統(tǒng)平均請求數(shù)。估算公式如下
*線程池大小 = ((線程 IO time + 線程 CPU time )/線程 CPU time ) CPU數(shù)目**
具體實踐
通過公式,我們了解到需要 3 個具體數(shù)值
一個請求所消耗的時間 (線程 IO time + 線程 CPU time) 該請求計算時間 (線程 CPU time) CPU 數(shù)目
請求消耗時間
Web 服務(wù)容器中,可以通過 Filter 來攔截獲取該請求前后消耗的時間
public class MoniterFilter implements Filter { private static final Logger logger = LoggerFactory.getLogger(MoniterFilter.class); @Override public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { long start = System.currentTimeMillis(); HttpServletRequest httpRequest = (HttpServletRequest) request; HttpServletResponse httpResponse = (HttpServletResponse) response; String uri = httpRequest.getRequestURI(); String params = getQueryString(httpRequest); try { chain.doFilter(httpRequest, httpResponse); } finally { long cost = System.currentTimeMillis() - start; logger.info("access url [{}{}], cost time [{}] ms )", uri, params, cost); } private String getQueryString(HttpServletRequest req) { StringBuilder buffer = new StringBuilder("?"); Enumeration<String> emParams = req.getParameterNames(); try { while (emParams.hasMoreElements()) { String sParam = emParams.nextElement(); String sValues = req.getParameter(sParam); buffer.append(sParam).append("=").append(sValues).append("&"); } return buffer.substring(0, buffer.length() - 1); } catch (Exception e) { logger.error("get post arguments error", buffer.toString()); } return ""; } }
CPU 計算時間
CPU 計算時間 = 請求總耗時 - CPU IO time
假設(shè)該請求有一個查詢 DB 的操作,只要知道這個查詢 DB 的耗時(CPU IO time),計算的時間不就出來了嘛,我們看一下怎么才能簡潔,明了的記錄 DB 查詢的耗時。
通過(JDK 動態(tài)代理/ CGLIB)的方式添加 AOP 切面,來獲取線程 IO 耗時。代碼如下,請參考:
public class DaoInterceptor implements MethodInterceptor { private static final Logger logger = LoggerFactory.getLogger(DaoInterceptor.class); @Override public Object invoke(MethodInvocation invocation) throws Throwable { StopWatch watch = new StopWatch(); watch.start(); Object result = null; Throwable t = null; try { result = invocation.proceed(); } catch (Throwable e) { t = e == null ? null : e.getCause(); throw e; } finally { watch.stop(); logger.info("({}ms)", watch.getTotalTimeMillis()); } return result; } }
CPU 數(shù)目
邏輯 CPU 個數(shù) ,設(shè)置線程池大小的時候參考的 CPU 個數(shù)
cat /proc/cpuinfo| grep "processor"| wc -l
看完上述內(nèi)容,你們對Java中怎么設(shè)置線程池的大小有進一步的了解嗎?如果還想了解更多知識或者相關(guān)內(nèi)容,請關(guān)注億速云行業(yè)資訊頻道,感謝大家的支持。
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。