前面幾篇博文基本上總結了一下java并發里的一些內容，這篇博文主要從一個問題入手，看看都能用到前面總結的哪些并發技術去解決。
題目描述：
模擬一個場景：處理16條日志記錄，每條日志記錄打印時間需要1秒，正常情況下如果將這16條記錄去部打完需要16秒，現在為了提高效率，準備開啟4個線程去打印，4秒鐘打印完，實現這個demo。
先來分析一下這個題目，關于這16條日志記錄，我們可以在主線程中產生出來，這沒用什么難度，關鍵是開啟4個線程去執行，現在有兩種思路：一種是日志的產生和打印日志的線程在邏輯上分開；一種是日志的產生和打印日志的線程在邏輯上不是分開的。這樣說可能有點晦澀，下面我針對這兩種思路，寫個實現的demo就好理解了。
思路一
日志產生和日志打印在邏輯上是分開的。
這相當于兩條戰線： 一條戰線在不停的產生日志，另一個戰線在不停的打印日志。很明顯會想到阻塞隊列的使用，產生日志不停的往阻塞隊列中塞，打印日志不停的從阻塞隊列中取，阻塞隊列的大小可以自己設置，可以設置16個，也可以設置為1個，這都不影響執行。所以會用到BlockingQueue，下面看一下實現的demo：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
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如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
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編程一道多線程問題實例代碼的全部內容，希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題，如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！
原文鏈接：http://blog.csdn.net/eson_15/article/details/51593139
