前面幾篇博文基本上總結了一下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編程一道多線程問題實例代碼的全部內容,希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題,如有不足之處,歡迎留言指出。感謝朋友們對本站的支持!