快捷導(dǎo)航

Java編程一道多線程問題實例代碼

更新時間：2018年02月07日 08:43:26 作者：eson_15

這篇文章主要介紹了Java編程一道多線程問題實例代碼，分享了相關(guān)代碼示例，小編覺得還是挺不錯的，具有一定借鑒價值，需要的朋友可以參考下

前面幾篇博文基本上總結(jié)了一下java并發(fā)里的一些內(nèi)容，這篇博文主要從一個問題入手，看看都能用到前面總結(jié)的哪些并發(fā)技術(shù)去解決。

題目描述：

模擬一個場景：處理16條日志記錄，每條日志記錄打印時間需要1秒，正常情況下如果將這16條記錄去部打完需要16秒，現(xiàn)在為了提高效率，準備開啟4個線程去打印，4秒鐘打印完，實現(xiàn)這個demo。

　　先來分析一下這個題目，關(guān)于這16條日志記錄，我們可以在主線程中產(chǎn)生出來，這沒用什么難度，關(guān)鍵是開啟4個線程去執(zhí)行，現(xiàn)在有兩種思路：一種是日志的產(chǎn)生和打印日志的線程在邏輯上分開；一種是日志的產(chǎn)生和打印日志的線程在邏輯上不是分開的。這樣說可能有點晦澀，下面我針對這兩種思路，寫個實現(xiàn)的demo就好理解了。

思路一

日志產(chǎn)生和日志打印在邏輯上是分開的。

　　這相當于兩條戰(zhàn)線：一條戰(zhàn)線在不停的產(chǎn)生日志，另一個戰(zhàn)線在不停的打印日志。很明顯會想到阻塞隊列的使用，產(chǎn)生日志不停的往阻塞隊列中塞，打印日志不停的從阻塞隊列中取，阻塞隊列的大小可以自己設(shè)置，可以設(shè)置16個，也可以設(shè)置為1個，這都不影響執(zhí)行。所以會用到BlockingQueue，下面看一下實現(xiàn)的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);
				//將產(chǎn)生的日志塞到阻塞隊列中去
			}
			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();
		}
	}
}

　　這就好比一個系統(tǒng)正在運作，一邊不停的產(chǎn)生日志，一邊在不停的開啟多個線程去打印日志信息，這個demo就寫好了，運行結(jié)果就不貼了。

思路二

日志產(chǎn)生和日志打印在邏輯上不是分開的。

　　這種思路就是，我產(chǎn)生日志的同時，你就給我打印出來，四個線程一起干！那么這種思路的話，就得用到線程池了，我一開始創(chuàng)建一個線程池，里面裝了4個線程，然后產(chǎn)生日志的時候，我讓這個線程池拿線程去執(zhí)行它即可。demo如下：

public class Practice1 {
	public static void main(String[] args) {
		ExecutorService service = Executors.newFixedThreadPool(4);
		//創(chuàng)建一個線程池
		System.out.println("begin:" + (System.currentTimeMillis()/1000));
		for (int i = 0; i < 16; i ++) {
			final String log = "" + (i+1);
			//表示一個日志
			service.execute(new Runnable() {
				//拿一個線程去執(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)于這個問題，就總結(jié)到這吧，把這兩種思路搞清楚一般就可以有效的解決了。