【java併發】一道多線程問題

題目描述： 
模擬一個場景：處理16條日誌記錄，每條日誌記錄打印時間須要1秒，正常狀況下若是將這16條記錄去部打完須要16秒，如今爲了提升效率，準備開啓4個線程去打印，4秒鐘打印完，實現這個demo。

先來分析一下這個題目，關於這16條日誌記錄，咱們能夠在主線程中產生出來，這沒用什麼難度，關鍵是開啓4個線程去執行，如今有兩種思路：一種是日誌的產生和打印日誌的線程在邏輯上分開；一種是日誌的產生和打印日誌的線程在邏輯上不是分開的。這樣說可能有點晦澀，下面我針對這兩種思路，寫個實現的demo就好理解了。

思路一：日誌產生和日誌打印在邏輯上是分開的。 

這至關於兩條戰線： 一條戰線在不停的產生日誌，另外一個戰線在不停的打印日誌。很明顯會想到阻塞隊列的使用，產生日誌不停的往阻塞隊列中塞，打印日誌不停的從阻塞隊列中取，阻塞隊列的大小能夠本身設置，能夠設置16個，也能夠設置爲1個，這都不影響執行。因此會用到BlockingQueue，下面看一下實現的demo：

public class QuestionOne {

    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就寫好了，運行結果就不貼了。

思路二：日誌產生和日誌打印在邏輯上不是分開的。

public class QuestionOnePool {

    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秒
            System.out.println(Thread.currentThread().getName() + "--結束打印-"
                    + log + "---" + (System.currentTimeMillis()/1000));
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}