線程池簡(jiǎn)單應(yīng)用（不做深入分析）

microcosm1994 發(fā)布于2019-08-15 13:49 / 2645人閱讀

摘要：創(chuàng)建實(shí)現(xiàn)類執(zhí)行結(jié)束再創(chuàng)建測(cè)試類，并創(chuàng)建線程池創(chuàng)建線程池說(shuō)明類和接口提供線程池操作的接口提供方法，傳入的實(shí)例即本例中的的實(shí)現(xiàn)類，提供種構(gòu)造方法。時(shí)間單位線程工廠用來(lái)創(chuàng)建線程的。

創(chuàng)建Runnable實(shí)現(xiàn)類

package ThreadTest;
/**
 * 
 * @author Administrator
 *
 */
public class RunnableTest implements Runnable {
    
    @Override
    public void run() {
        for (int i = 0; i < 20; i++) {
            System.out.println(Thread.currentThread().getName()+"--"+i);
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println(Thread.currentThread().getName()+"--執(zhí)行結(jié)束");
    }

}

再創(chuàng)建測(cè)試類，并創(chuàng)建線程池

package ThreadTest;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import com.google.common.util.concurrent.ThreadFactoryBuilder;

public class ThreadPoolTest {

    public static void main(String[] args) {
        ThreadFactory threadFactory=new ThreadFactoryBuilder().setNameFormat("myThreadPool-%d").build();
        LinkedBlockingQueue workQueue=new LinkedBlockingQueue(250);
        ExecutorService executor=new ThreadPoolExecutor(3, 5, 20, TimeUnit.SECONDS, workQueue, threadFactory);//創(chuàng)建線程池
        for(int i=0;i<10;i++){
            RunnableTest test=new RunnableTest();
            executor.execute(test);
        }
    }

}

說(shuō)明
類和接口

1 ExecutorService 提供線程池操作的接口
    提供void execute(Runnable command)方法，傳入Runnable的實(shí)例即本例中的test;
2 ThreadPoolExecutor ExecutorService的實(shí)現(xiàn)類，提供4種構(gòu)造方法。（只寫(xiě)最后一個(gè)）
   new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, handler);
   （1）corePoolSize 核心線程數(shù)，即本例中填寫(xiě)的數(shù)字3。
   （2）workQueue任務(wù)隊(duì)列，負(fù)責(zé)存放超過(guò)核心線程數(shù)的請(qǐng)求，可指定大小如本例中LinkedBlockingQueue(250)的250;
   （3）maximumPoolSize 創(chuàng)建最大線程數(shù)，只有當(dāng)請(qǐng)求超過(guò)任務(wù)隊(duì)列容量和核心線程數(shù)量是才會(huì)創(chuàng)建，即本例中250+3=253；
   （4）handler 當(dāng)請(qǐng)求超過(guò)最大線程數(shù)maximumPoolSize和任務(wù)隊(duì)列容量之和時(shí)，會(huì)調(diào)用。（可以查看該RejectedExecutionHandler接口的幾個(gè)實(shí)現(xiàn)類，定義了處理策略，一般默認(rèn)就行）
   （5）keepAliveTime 線程存活時(shí)間，對(duì)擋前線程多于核心線程數(shù)量時(shí)會(huì)殺死多于的線程保留到核心線程數(shù)量。
   （6）unit 時(shí)間單位
   （7）ThreadFactory 線程工廠 用來(lái)創(chuàng)建線程的。（采用Google guava來(lái)創(chuàng)建的）

運(yùn)行展示

創(chuàng)建了0,1,2 三個(gè)核心線程（當(dāng)有請(qǐng)求時(shí)核心線程才會(huì)創(chuàng)建，除非手動(dòng)設(shè)置）；
運(yùn)行過(guò)程中可以通過(guò)動(dòng)態(tài)更改corePoolSize和maximumPoolSize 的大小，但是只有ThreadPoolExecutor提供了set方法。