java線程池

233jl 發(fā)布于2019-08-14 16:32 / 1205人閱讀

摘要：本篇來看下線程池相關(guān)技術(shù)的實(shí)現(xiàn)和使用方式。時(shí)間單位這個(gè)線程池中線程處理任務(wù)的的任務(wù)隊(duì)列。上面的例子中我們向線程池中提交了一個(gè)，并接受一個(gè)返回值。

本篇來看下java線程池相關(guān)技術(shù)的實(shí)現(xiàn)和使用方式。

0x01 線程的實(shí)現(xiàn)

一開始我們想要實(shí)現(xiàn)多線程最通常的做法是：

new Thread(new Runnable() {
    public void run() {
        System.out.println("raw thread");
    }
}).start();

這種方式，這種實(shí)現(xiàn)方式也沒有什么不好，只是如果線程一多的話不好對(duì)所有的線程進(jìn)行統(tǒng)一管理。然后java有了線程池技術(shù)，我們可以通過線程池技術(shù)來替換實(shí)現(xiàn)上面的方式。

0x02 線程池

ExecutorService executorPool = Executors.newCachedThreadPool();
Future future = executorPool.submit(new Callable() {
    public String call() throws Exception {
        return "future finish";
    }
});
try {
    System.out.println(future.get());
} catch (Exception e) {
    e.printStackTrace();
}

Executors有如下幾種方式創(chuàng)建線程：

newCachedThreadPool

newFixedThreadPool

newScheduledThreadPool

上面三種方式最終都是調(diào)用ThreadPoolExecutor的構(gòu)造函數(shù)進(jìn)行線程池的創(chuàng)建，只是傳入的參數(shù)不一樣，而實(shí)現(xiàn)不同的線程池對(duì)象。

ThreadPoolExecutor(int corePoolSize,
                      int maximumPoolSize,
                      long keepAliveTime,
                      TimeUnit unit,
                      BlockingQueue workQueue,
                      ThreadFactory threadFactory,
                      RejectedExecutionHandler handler)

corePoolSize：創(chuàng)建線程池時(shí)創(chuàng)建多少個(gè)線程。

maximumPoolSize：這個(gè)線程池中對(duì)多能有多少個(gè)線程。

keepAliveTime：當(dāng)線程數(shù)量超過corePoolSize時(shí)，多余的空閑線程最大的存活時(shí)間。也就是說多余的線程在keepAliveTime時(shí)間還是沒有處理任何的任務(wù)將會(huì)被終止。

unit：時(shí)間單位

workQueue：這個(gè)線程池中線程處理任務(wù)的的任務(wù)隊(duì)列。

threadFactory：創(chuàng)建新線程的線程工廠。

handler：當(dāng)線程數(shù)量達(dá)到maximumPoolSize，對(duì)新加入的任務(wù)的處理策略。一般很少使用這個(gè)參數(shù)基本都采用默認(rèn)的handler。

上面的例子中我們向線程池中提交了一個(gè)Callable，并接受一個(gè)返回值Future。Callable可能會(huì)是一個(gè)非常耗時(shí)的操作但是使用方有不想阻塞等待其返回再繼續(xù)執(zhí)行，這時(shí)Callable執(zhí)行完后會(huì)將結(jié)果放到Future中，使用方可以在需要的時(shí)候去判斷是否Callable已經(jīng)執(zhí)行完成，如果完成就可以通過Future拿到其返回值。

0x03 ScheduledExecutorService

任務(wù)定時(shí)調(diào)度線程的使用：

        ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
        scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
            public void run() {
                System.out.println("schedule task with fixed rate:" + System.currentTimeMillis());
            }
        }, 2000, 1000, TimeUnit.MILLISECONDS);

        scheduledExecutorService.scheduleWithFixedDelay(new Runnable() {
            public void run() {
                System.out.println("schedule task with fixed delay:" + System.currentTimeMillis());
                int count = Integer.MAX_VALUE;
                while (count-- > 0){

                }
                System.out.println("time:" + System.currentTimeMillis());
            }
        }, 2000, 1000, TimeUnit.MILLISECONDS);

ScheduledExecutorService有兩種定時(shí)調(diào)度的方式：

scheduleAtFixedRate：以固定速率進(jìn)行調(diào)度，意思是任何兩個(gè)被調(diào)度的任務(wù)之間的時(shí)間間隔是固定的。第二個(gè)任務(wù)的調(diào)度時(shí)間（開始執(zhí)行時(shí)間）= 第一個(gè)任務(wù)的調(diào)度時(shí)間 + 間隔時(shí)間

scheduleWithFixedDelay：第二個(gè)任務(wù)的調(diào)度時(shí)間 = 第一個(gè)任務(wù)的調(diào)度時(shí)間 + 第一個(gè)任務(wù)的執(zhí)行時(shí)間 + 間隔時(shí)間

0x04 Timer定時(shí)任務(wù)

上面介紹了ScheduledExecutorService來做定時(shí)任務(wù)，在編程的過程中還可以使用Timer來做定時(shí)任務(wù)，代碼如下：

    timer.scheduleAtFixedRate(new TimerTask() {

            @Override
            public void run() {
                try {
                    doSomething();
                } catch (Exception e) {
                    System.out.println("timer excute exception", e);
                }
            }
        }, 1000 * 3, 1000);

其第一參數(shù)是一個(gè)TimerTask，第二第三個(gè)參數(shù)scheduledExecutorService.scheduleAtFixedRate這個(gè)調(diào)用的第二三個(gè)參數(shù)一致。

0x05 參考

我覺得最好的參考還是閱讀相關(guān)源碼去理解Executor的使用方式，這樣自己才能理解的比較深入同時(shí)做到活學(xué)活用。
線程池的的核心實(shí)現(xiàn)ThreadPoolExecutor，想了解更多還是自己去look look源碼吧。