您好,登錄后才能下訂單哦!
前面幾篇博文基本上總結(jié)了一下java并發(fā)里的一些內(nèi)容,這篇博文主要從一個(gè)問(wèn)題入手,看看都能用到前面總結(jié)的哪些并發(fā)技術(shù)去解決。
模擬一個(gè)場(chǎng)景:處理16條日志記錄,每條日志記錄打印時(shí)間需要1秒,正常情況下如果將這16條記錄去部打完需要16秒,現(xiàn)在為了提高效率,準(zhǔn)備開(kāi)啟4個(gè)線程去打印,4秒鐘打印完,實(shí)現(xiàn)這個(gè)demo。
先來(lái)分析一下這個(gè)題目,關(guān)于這16條日志記錄,我們可以在主線程中產(chǎn)生出來(lái),這沒(méi)用什么難度,關(guān)鍵是開(kāi)啟4個(gè)線程去執(zhí)行,現(xiàn)在有兩種思路:一種是日志的產(chǎn)生和打印日志的線程在邏輯上分開(kāi);一種是日志的產(chǎn)生和打印日志的線程在邏輯上不是分開(kāi)的。這樣說(shuō)可能有點(diǎn)晦澀,下面我針對(duì)這兩種思路,寫(xiě)個(gè)實(shí)現(xiàn)的demo就好理解了。
日志產(chǎn)生和日志打印在邏輯上是分開(kāi)的。
這相當(dāng)于兩條戰(zhàn)線: 一條戰(zhàn)線在不停的產(chǎn)生日志,另一個(gè)戰(zhàn)線在不停的打印日志。很明顯會(huì)想到阻塞隊(duì)列的使用,產(chǎn)生日志不停的往阻塞隊(duì)列中塞,打印日志不停的從阻塞隊(duì)列中取,阻塞隊(duì)列的大小可以自己設(shè)置,可以設(shè)置16個(gè),也可以設(shè)置為1個(gè),這都不影響執(zhí)行。所以會(huì)用到BlockingQueue,下面看一下實(shí)現(xiàn)的demo:
public class Practice1 { public static void main(String[] args) { //定義一個(gè)阻塞隊(duì)列,隊(duì)列大小可以裝16個(gè)信息 BlockingQueue<String> queue = new ArrayBlockingQueue<String>(16); for (int i = 0; i < 4; i ++) { //開(kāi)啟四個(gè)線程去阻塞隊(duì)列中取日志打印 new Thread(new Runnable() { @Override public void run() { while(true) { try { String log = queue.take(); //取日志 parseLog(log); //打印日志 } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } ).start(); } System.out.println("begin:" + (System.currentTimeMillis()/1000)); for (int i = 0; i < 16; i ++) { final String log = "" + (i+1); //表示一個(gè)日志 try { queue.put(log); //將產(chǎn)生的日志塞到阻塞隊(duì)列中去 } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } public static void parseLog(String log) { //打印日志的方法 System.out.println(Thread.currentThread().getName() + "---" + log + "---" + (System.currentTimeMillis()/1000)); try { Thread.sleep(1000); //模擬打印一次日志需要1秒 } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
這就好比一個(gè)系統(tǒng)正在運(yùn)作,一邊不停的產(chǎn)生日志,一邊在不停的開(kāi)啟多個(gè)線程去打印日志信息,這個(gè)demo就寫(xiě)好了,運(yùn)行結(jié)果就不貼了。
日志產(chǎn)生和日志打印在邏輯上不是分開(kāi)的。
這種思路就是,我產(chǎn)生日志的同時(shí),你就給我打印出來(lái),四個(gè)線程一起干!那么這種思路的話,就得用到線程池了,我一開(kāi)始創(chuàng)建一個(gè)線程池,里面裝了4個(gè)線程,然后產(chǎn)生日志的時(shí)候,我讓這個(gè)線程池拿線程去執(zhí)行它即可。demo如下:
public class Practice1 { public static void main(String[] args) { ExecutorService service = Executors.newFixedThreadPool(4); //創(chuàng)建一個(gè)線程池 System.out.println("begin:" + (System.currentTimeMillis()/1000)); for (int i = 0; i < 16; i ++) { final String log = "" + (i+1); //表示一個(gè)日志 service.execute(new Runnable() { //拿一個(gè)線程去執(zhí)行 @Override public void run() { parseLog(log); } } ); } service.shutdown(); //最后別忘了關(guān)掉線程池 } public static void parseLog(String log) { System.out.println(Thread.currentThread().getName() + "---" + log + "---" + (System.currentTimeMillis()/1000)); try { Thread.sleep(1000); //模擬打印一次日志需要1秒 } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
關(guān)于這個(gè)問(wèn)題,就總結(jié)到這吧,把這兩種思路搞清楚一般就可以有效的解決了。
以上就是本文關(guān)于Java編程一道多線程問(wèn)題實(shí)例代碼的全部?jī)?nèi)容,希望對(duì)大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站其他相關(guān)專題,如有不足之處,歡迎留言指出。感謝朋友們對(duì)本站的支持!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。