溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
前面幾篇博文基本上總結了一下java并發里的一些內容，這篇博文主要從一個問題入手，看看都能用到前面總結的哪些并發技術去解決。
模擬一個場景：處理16條日志記錄，每條日志記錄打印時間需要1秒，正常情況下如果將這16條記錄去部打完需要16秒，現在為了提高效率，準備開啟4個線程去打印，4秒鐘打印完，實現這個demo。
先來分析一下這個題目，關于這16條日志記錄，我們可以在主線程中產生出來，這沒用什么難度，關鍵是開啟4個線程去執行，現在有兩種思路：一種是日志的產生和打印日志的線程在邏輯上分開；一種是日志的產生和打印日志的線程在邏輯上不是分開的。這樣說可能有點晦澀，下面我針對這兩種思路，寫個實現的demo就好理解了。
日志產生和日志打印在邏輯上是分開的。
這相當于兩條戰線： 一條戰線在不停的產生日志，另一個戰線在不停的打印日志。很明顯會想到阻塞隊列的使用，產生日志不停的往阻塞隊列中塞，打印日志不停的從阻塞隊列中取，阻塞隊列的大小可以自己設置，可以設置16個，也可以設置為1個，這都不影響執行。所以會用到BlockingQueue，下面看一下實現的demo：
public class Practice1 {
public static void main(String[] args) {
//定義一個阻塞隊列，隊列大小可以裝16個信息
BlockingQueue<String> queue = new ArrayBlockingQueue<String>(16);
for (int i = 0; i < 4; i ++) {
//開啟四個線程去阻塞隊列中取日志打印
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);
//表示一個日志
try {
queue.put(log);
//將產生的日志塞到阻塞隊列中去
}
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();
}
}
}
這就好比一個系統正在運作，一邊不停的產生日志，一邊在不停的開啟多個線程去打印日志信息，這個demo就寫好了，運行結果就不貼了。
日志產生和日志打印在邏輯上不是分開的。
這種思路就是，我產生日志的同時，你就給我打印出來，四個線程一起干！那么這種思路的話，就得用到線程池了，我一開始創建一個線程池，里面裝了4個線程，然后產生日志的時候，我讓這個線程池拿線程去執行它即可。demo如下：
public class Practice1 {
public static void main(String[] args) {
ExecutorService service = Executors.newFixedThreadPool(4);
//創建一個線程池
System.out.println("begin:" + (System.currentTimeMillis()/1000));
for (int i = 0; i < 16; i ++) {
final String log = "" + (i+1);
//表示一個日志
service.execute(new Runnable() {
//拿一個線程去執行
@Override
public void run() {
parseLog(log);
}
}
);
}
service.shutdown();
//最后別忘了關掉線程池
}
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();
}
}
}
關于這個問題，就總結到這吧，把這兩種思路搞清楚一般就可以有效的解決了。
以上就是本文關于Java編程一道多線程問題實例代碼的全部內容，希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題，如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
