快捷導(dǎo)航

解讀線程池-Executors的newSingleThreadExecutor和newFixedThreadPool(1)區(qū)別

更新時(shí)間：2024年08月06日 14:46:35 作者：Ahuuua

這篇文章主要介紹了解讀線程池-Executors的newSingleThreadExecutor和newFixedThreadPool(1)區(qū)別,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

線程池Executors的newSingleThreadExecutor和newFixedThreadPool(1)

與其他等效的newFixedThreadPool(1)不同

newSingleThreadExecutor返回的執(zhí)行器保證不可重新配置。

與其他等效的newScheduledThreadPool(1)不同

newSingleThreadScheduledExecutor返回的執(zhí)行器保證不可重新配置以使用其他線程。

newFixedThreadPool(1)的返回結(jié)果我們可以通過(guò)強(qiáng)轉(zhuǎn)變成ThreadPoolExecutor，但是這個(gè)類是可以自行指定線程數(shù)的。

我們可以通過(guò)setCorePoolSize方法來(lái)修改。

這樣也就是說(shuō)，這兩個(gè)方法的最大的區(qū)別是第一個(gè)方法可以修改線程的數(shù)量，如果用來(lái)指定線程數(shù)量為1是不安全的。

newSingleThreadExecutor方法則通過(guò)提供了一個(gè)包裝類完全堵住了這個(gè)漏洞。

舉個(gè)例子

拿newSingleThreadExecutor和newFixedThreadPool(1)舉例

import org.junit.Test;
 
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
 
public class ThreadPoolDemo {
    static class MyRunnable implements Runnable {
        @Override
        public void run() {
            System.out.println("開始");
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("結(jié)束" + Thread.currentThread().getName());
        }
    }
 
    @Test
    public void test() throws InterruptedException {
        //創(chuàng)建Runnable實(shí)例對(duì)象
        MyRunnable r = new MyRunnable();
 
        //創(chuàng)建線程池對(duì)象
        System.out.println("fixedThreadPool");
        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(1);//包含1個(gè)線程對(duì)象
        for (int i = 0; i < 10; i++) {
            fixedThreadPool.submit(r);
        }
        Thread.sleep(10000);
        /**
         * 以上輸出：
         * fixedThreadPool
         * 開始
         * 結(jié)束pool-1-thread-1
         * 開始
         * 結(jié)束pool-1-thread-1
         * 開始
         * 結(jié)束pool-1-thread-1
         * 開始
         * 結(jié)束pool-1-thread-1
         * 開始
         * 結(jié)束pool-1-thread-1
         * 開始
         * 結(jié)束pool-1-thread-1
         * 開始
         * 結(jié)束pool-1-thread-1
         * 開始
         * 結(jié)束pool-1-thread-1
         * 開始
         * 結(jié)束pool-1-thread-1
         * 開始
         * 結(jié)束pool-1-thread-1
         */
 
        System.out.println("singleThreadExecutor");
        ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
        for (int i = 0; i < 10; i++) {
            singleThreadExecutor.submit(r);
        }
        Thread.sleep(10000);
        /**
         * 以上輸出：
         * singleThreadExecutor
         * 開始
         * 結(jié)束pool-2-thread-1
         * 開始
         * 結(jié)束pool-2-thread-1
         * 開始
         * 結(jié)束pool-2-thread-1
         * 開始
         * 結(jié)束pool-2-thread-1
         * 開始
         * 結(jié)束pool-2-thread-1
         * 開始
         * 結(jié)束pool-2-thread-1
         * 開始
         * 結(jié)束pool-2-thread-1
         * 開始
         * 結(jié)束pool-2-thread-1
         * 開始
         * 結(jié)束pool-2-thread-1
         * 開始
         * 結(jié)束pool-2-thread-1
         */
 
        System.out.println("fixedThreadPool(5)");
        ((ThreadPoolExecutor) fixedThreadPool).setCorePoolSize(5);
        for (int i = 0; i < 10; i++) {
            fixedThreadPool.submit(r);
        }
        Thread.sleep(10000);
        /**
         * 以上輸出：
         * fixedThreadPool(5)
         * 開始
         * 開始
         * 開始
         * 開始
         * 開始
         * 結(jié)束pool-1-thread-1
         * 結(jié)束pool-1-thread-5
         * 結(jié)束pool-1-thread-2
         * 結(jié)束pool-1-thread-3
         * 結(jié)束pool-1-thread-4
         * 開始
         * 結(jié)束pool-1-thread-4
         * 開始
         * 結(jié)束pool-1-thread-4
         * 開始
         * 結(jié)束pool-1-thread-4
         * 開始
         * 結(jié)束pool-1-thread-4
         * 開始
         * 結(jié)束pool-1-thread-4
         * singleThreadExecutor(5)
         */
 
        System.out.println("singleThreadExecutor(5)");
        ((ThreadPoolExecutor) singleThreadExecutor).setCorePoolSize(5);
        for (int i = 0; i < 10; i++) {
            singleThreadExecutor.submit(r);
        }
        /**
         * 以下輸出：
         * Exception in thread "main" java.lang.ClassCastException: java.util.concurrent.Executors$FinalizableDelegatedExecutorService cannot be cast to java.util.concurrent.ThreadPoolExecutor
         * 	at ThreadPoolDemo.main(ThreadPoolDemo.java:33)
         */
    }
}