前面幾篇博文基本上總結了一下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 blocke.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 blocke.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 blocke.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 blocke.printStackTrace();}}}關於這個問題，就總結到這吧，把這兩種思路搞清楚一般就可以有效的解決了。
以上就是本文關於Java編程一道多線程問題實例代碼的全部內容，希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題，如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！