快捷導(dǎo)航

Java詳解使用線(xiàn)程池處理任務(wù)方法

更新時(shí)間：2022年05月07日 11:38:33 作者：遇安.112

java中經(jīng)常需要用到多線(xiàn)程來(lái)處理，我們非常不建議單純使用繼承Thread或者實(shí)現(xiàn)Runnable接口的方式來(lái)創(chuàng)建線(xiàn)程，那樣勢(shì)必有創(chuàng)建及銷(xiāo)毀線(xiàn)程耗費(fèi)資源、線(xiàn)程上下文切換問(wèn)題。同時(shí)創(chuàng)建過(guò)多的線(xiàn)程也可能引發(fā)資源耗盡的風(fēng)險(xiǎn)，這個(gè)時(shí)候引入線(xiàn)程池比較合理，方便線(xiàn)程任務(wù)的管理

什么是線(xiàn)程池？

線(xiàn)程池就是一個(gè)可以復(fù)用線(xiàn)程的技術(shù)。

不使用線(xiàn)程池的問(wèn)題：

如果用戶(hù)每發(fā)起一個(gè)請(qǐng)求，后臺(tái)就創(chuàng)建一個(gè)新線(xiàn)程來(lái)處理，下次新任務(wù)來(lái)了又要?jiǎng)?chuàng)建新線(xiàn)程，而創(chuàng)建新線(xiàn)程的開(kāi)銷(xiāo)是很大的，這樣會(huì)嚴(yán)重影響系統(tǒng)的性能。

線(xiàn)程池常見(jiàn)面試題：

1、臨時(shí)線(xiàn)程什么時(shí)候創(chuàng)建？

新任務(wù)提交時(shí)發(fā)現(xiàn)核心線(xiàn)程都在忙，任務(wù)隊(duì)列也滿(mǎn)了，并且還可以創(chuàng)建臨時(shí)線(xiàn)程，此時(shí)才會(huì)創(chuàng)建臨時(shí)線(xiàn)程。

2、什么時(shí)候會(huì)開(kāi)始拒絕任務(wù)？

核心線(xiàn)程和臨時(shí)線(xiàn)程都在忙，任務(wù)隊(duì)列也滿(mǎn)了，新的任務(wù)過(guò)來(lái)的時(shí)候才會(huì)開(kāi)始任務(wù)拒絕。

1、線(xiàn)程池處理Runnable任務(wù)

import java.util.concurrent.*;
public class 多線(xiàn)程_5線(xiàn)程池處理Runnable任務(wù) {
    public static void main(String[] args) {
        //線(xiàn)程池處理Runnable任務(wù)
        //創(chuàng)建線(xiàn)程池對(duì)象
        /*
         public ThreadPoolExecutor(int corePoolSize,//核心線(xiàn)程數(shù)量
                              int maximumPoolSize,//線(xiàn)程池可支持的最大線(xiàn)程數(shù)量
                              long keepAliveTime,//臨時(shí)線(xiàn)程的最大存活時(shí)間
                              TimeUnit unit,//指定存活時(shí)間的單位（秒，分等）
                              BlockingQueue<Runnable> workQueue,//指定任務(wù)隊(duì)列
                              ThreadFactory threadFactory,//指定用哪個(gè)線(xiàn)程工廠創(chuàng)建線(xiàn)程
                              RejectedExecutionHandler handler)//指定線(xiàn)程忙，任務(wù)滿(mǎn)了的時(shí)候，新任務(wù)來(lái)了怎么辦
         */
        ExecutorService pool=new ThreadPoolExecutor(3,5,
                6, TimeUnit.SECONDS,new ArrayBlockingQueue<>(5),
                Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
        //給任務(wù)線(xiàn)程池處理
        Runnable r=new MyExe();
        //三個(gè)核心線(xiàn)程
        pool.execute(r);
        pool.execute(r);
        pool.execute(r);
        //五個(gè)任務(wù)隊(duì)列（不創(chuàng)建臨時(shí)線(xiàn)程時(shí)，會(huì)發(fā)現(xiàn)只有三個(gè)線(xiàn)程，即核心線(xiàn)程量）
        pool.execute(r);
        pool.execute(r);
        pool.execute(r);
        pool.execute(r);
        pool.execute(r);
        //創(chuàng)建臨時(shí)線(xiàn)程(五個(gè)線(xiàn)程，即最大線(xiàn)程量)
        pool.execute(r);
        pool.execute(r);
        //不創(chuàng)建，拒絕策略被觸發(fā)
       // pool.execute(r);
        //關(guān)閉線(xiàn)程池（開(kāi)發(fā)中一般不會(huì)使用）
//        pool.shutdownNow();//立即關(guān)閉，即使任務(wù)沒(méi)有執(zhí)行完畢。會(huì)丟失任務(wù)的！
//        pool.shutdown();//會(huì)等待任務(wù)全部執(zhí)行完畢后再關(guān)閉（建議使用）
    }
}
class MyExe implements Runnable{
    public void run(){
        for (int i = 1; i <=6 ; i++) {
            System.out.println(Thread.currentThread().getName()+"正在執(zhí)行："+i+"次");
        }
        //因?yàn)楫?dāng)前案例任務(wù)太簡(jiǎn)單，我們需要?jiǎng)?chuàng)建臨時(shí)隊(duì)列需要讓三個(gè)核心線(xiàn)程忙，五個(gè)任務(wù)隊(duì)列排滿(mǎn),所以讓線(xiàn)程休眠以增加任務(wù)時(shí)間
        try {
            System.out.println(Thread.currentThread().getName()+"任務(wù)與線(xiàn)程綁定，線(xiàn)程進(jìn)入了休眠");
            Thread.sleep(1000000);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

2、線(xiàn)程池處理Callable任務(wù)

import java.util.concurrent.*;
public class 多線(xiàn)程_5線(xiàn)程池處理Callable任務(wù) {
    public static void main(String[] args) throws Exception {
        //線(xiàn)程池處理Callable任務(wù)
        //創(chuàng)建線(xiàn)程池對(duì)象
        /*
         public ThreadPoolExecutor(int corePoolSize,//核心線(xiàn)程數(shù)量
                              int maximumPoolSize,//線(xiàn)程池可支持的最大線(xiàn)程數(shù)量
                              long keepAliveTime,//臨時(shí)線(xiàn)程的最大存活時(shí)間
                              TimeUnit unit,//指定存活時(shí)間的單位（秒，分等）
                              BlockingQueue<Runnable> workQueue,//指定任務(wù)隊(duì)列
                              ThreadFactory threadFactory,//指定用哪個(gè)線(xiàn)程工廠創(chuàng)建線(xiàn)程
                              RejectedExecutionHandler handler)//指定線(xiàn)程忙，任務(wù)滿(mǎn)了的時(shí)候，新任務(wù)來(lái)了怎么辦
         */
        ExecutorService pool=new ThreadPoolExecutor(3,5,
                6, TimeUnit.SECONDS,new ArrayBlockingQueue<>(5),
                Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
        //給任務(wù)線(xiàn)程池處理
//        Callable c=new MyCallable2(100);
//        pool.submit(c);
       Future<String> f1=pool.submit(new MyCallable2(100));
        Future<String> f2=pool.submit(new MyCallable2(200));
        Future<String> f3=pool.submit(new MyCallable2(300));
        Future<String> f4=pool.submit(new MyCallable2(400));
        Future<String> f5=pool.submit(new MyCallable2(500));
//        String str=f1.get();
//        System.out.println(str);
        System.out.println(f1.get());
        System.out.println(f2.get());
        System.out.println(f3.get());
        System.out.println(f4.get());
        System.out.println(f5.get());
    }
}
class MyCallable2 implements Callable<String> {
    //                               v(泛型)
    private int n;
    public MyCallable2(int n) {
        this.n = n;
    }
    //重寫(xiě)call方法
    //案例：加法
    public String call() throws Exception {
        int sum = 0;
        for (int i = 1; i <=n; i++) {
            sum += i;
        }
        return Thread.currentThread().getName()+"執(zhí)行 1-"+n+"的和，結(jié)果為：" + sum;
    }
}