快捷導(dǎo)航

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

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

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

什么是線程池？

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

不使用線程池的問題：

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

線程池常見面試題：

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

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

2、什么時候會開始拒絕任務(wù)？

核心線程和臨時線程都在忙，任務(wù)隊列也滿了，新的任務(wù)過來的時候才會開始任務(wù)拒絕。

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

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

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

import java.util.concurrent.*;
public class 多線程_5線程池處理Callable任務(wù) {
    public static void main(String[] args) throws Exception {
        //線程池處理Callable任務(wù)
        //創(chuàng)建線程池對象
        /*
         public ThreadPoolExecutor(int corePoolSize,//核心線程數(shù)量
                              int maximumPoolSize,//線程池可支持的最大線程數(shù)量
                              long keepAliveTime,//臨時線程的最大存活時間
                              TimeUnit unit,//指定存活時間的單位（秒，分等）
                              BlockingQueue<Runnable> workQueue,//指定任務(wù)隊列
                              ThreadFactory threadFactory,//指定用哪個線程工廠創(chuàng)建線程
                              RejectedExecutionHandler handler)//指定線程忙，任務(wù)滿了的時候，新任務(wù)來了怎么辦
         */
        ExecutorService pool=new ThreadPoolExecutor(3,5,
                6, TimeUnit.SECONDS,new ArrayBlockingQueue<>(5),
                Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
        //給任務(wù)線程池處理
//        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;
    }
    //重寫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;
    }
}