Java編程一道多線程問題實(shí)例代碼

來源：本站原創(chuàng)|時(shí)間：2020-01-10|欄目：Java編程|點(diǎn)擊：次

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

題目描述：

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

　　先來分析一下這個(gè)題目，關(guān)于這16條日志記錄，我們可以在主線程中產(chǎn)生出來，這沒用什么難度，關(guān)鍵是開啟4個(gè)線程去執(zhí)行，現(xiàn)在有兩種思路：一種是日志的產(chǎn)生和打印日志的線程在邏輯上分開；一種是日志的產(chǎn)生和打印日志的線程在邏輯上不是分開的。這樣說可能有點(diǎn)晦澀，下面我針對這兩種思路，寫個(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<String> queue = new ArrayBlockingQueue<String>(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í)，你就給我打印出來，四個(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è)問題，就總結(jié)到這吧，把這兩種思路搞清楚一般就可以有效的解決了。