java線(xiàn)程池

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

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

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

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

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

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

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

0x02 線(xiàn)程池

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)建線(xiàn)程：

newCachedThreadPool

newFixedThreadPool

newScheduledThreadPool

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

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

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

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

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

unit：時(shí)間單位

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

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

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

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

0x03 ScheduledExecutorService

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

        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í)間（開(kāi)始執(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來(lái)做定時(shí)任務(wù)，在編程的過(guò)程中還可以使用Timer來(lái)做定時(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 參考

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

GPU云服務(wù)器云服務(wù)器 java線(xiàn)程池線(xiàn)程數(shù)量 java 線(xiàn)程池線(xiàn)程池java java線(xiàn)程池

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/66217.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

233jl

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

Python控制單片機(jī) TPYBoard MicroPython v202鏈接DTH11 溫濕度 m

閱讀 1330·2021-11-24 09:38
Web優(yōu)化躬行記（5）——網(wǎng)站優(yōu)化

閱讀 3268·2021-11-22 12:03
域名續(xù)費(fèi)貴怎么辦？合理利用域名商家轉(zhuǎn)入優(yōu)惠省錢(qián)策略

閱讀 4203·2021-11-11 10:59
前程無(wú)憂(yōu)崗位數(shù)據(jù)爬取+Tableau可視化分析

閱讀 2334·2021-09-28 09:36
高性能MySQL讀書(shū)筆記(2)--MySQL基準(zhǔn)測(cè)試

閱讀 1043·2021-09-09 09:32
RAKsmart新增彈性云服務(wù)器首推硅谷機(jī)房可選優(yōu)化/精品/CN2線(xiàn)路

閱讀 3434·2021-08-05 10:00
運(yùn)維日迎新，歡迎“U仔”——UCloud吉祥物正式出道

閱讀 2542·2021-07-23 15:30
css記錄收集

閱讀 2985·2019-08-30 13:12

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專(zhuān)欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

java線(xiàn)程池

相關(guān)文章