前面幾篇博文基本上總結(jié)了一下java并發(fā)里的一些內(nèi)容，這篇博文主要從一個(gè)問(wèn)題入手，看看都能用到前面總結(jié)的哪些并發(fā)技術(shù)去解決。
唐山網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)！從網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站等網(wǎng)站項(xiàng)目制作，到程序開發(fā)，運(yùn)營(yíng)維護(hù)。創(chuàng)新互聯(lián)自2013年創(chuàng)立以來(lái)到現(xiàn)在10年的時(shí)間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來(lái)保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)。
模擬一個(gè)場(chǎng)景：處理16條日志記錄，每條日志記錄打印時(shí)間需要1秒，正常情況下如果將這16條記錄去部打完需要16秒，現(xiàn)在為了提高效率，準(zhǔn)備開啟4個(gè)線程去打印，4秒鐘打印完，實(shí)現(xiàn)這個(gè)demo。
先來(lái)分析一下這個(gè)題目，關(guān)于這16條日志記錄，我們可以在主線程中產(chǎn)生出來(lái)，這沒(méi)用什么難度，關(guān)鍵是開啟4個(gè)線程去執(zhí)行，現(xiàn)在有兩種思路：一種是日志的產(chǎn)生和打印日志的線程在邏輯上分開；一種是日志的產(chǎn)生和打印日志的線程在邏輯上不是分開的。這樣說(shuō)可能有點(diǎn)晦澀，下面我針對(duì)這兩種思路，寫個(gè)實(shí)現(xiàn)的demo就好理解了。
日志產(chǎn)生和日志打印在邏輯上是分開的。
這相當(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 queue = new ArrayBlockingQueue(16);
for (int i = 0; i < 4; 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)生日志，一邊在不停的開啟多個(gè)線程去打印日志信息，這個(gè)demo就寫好了，運(yùn)行結(jié)果就不貼了。
日志產(chǎn)生和日志打印在邏輯上不是分開的。
這種思路就是，我產(chǎn)生日志的同時(shí)，你就給我打印出來(lái)，四個(gè)線程一起干！那么這種思路的話，就得用到線程池了，我一開始創(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ì)本站的支持！
