Apakah empat kumpulan benang yang disertakan dengan Java?

Apakah empat kumpulan benang yang dipratentukan di Jawa?

• newSingleThreadExexcutor: kumpulan benang dengan sebilangan utas (bilangan utas teras = bilangan maksimum utas = 1)

• newFixedThreadPool: utas dengan bilangan benang yang tetap Pool (bilangan utas teras = bilangan utas maksimum = tersuai)

• newCacheThreadPool: Kumpulan benang boleh cache (bilangan utas teras = 0, bilangan utas maksimum = Integer.MAX_VALUE)

• newScheduledThreadPool: Kumpulan benang yang menyokong tugas berjadual atau berkala (bilangan utas teras = tersuai, bilangan maksimum utas = Integer.MAX_VALUE)

Empat jenis benang Apakah perbezaan antara kolam?

Empat kelas kumpulan benang di atas semuanya mewarisi ThreadPoolExecutor dan terus mengembalikan ThreadPoolExecutor (parameter) baharu apabila dibuat Perbezaan antara mereka ialah parameter dalam ThreadPoolExecutor (parameter) yang ditentukan adalah berbeza dan ThreadPoolExecutor mewarisi antara muka ExecutorService. kelas

• newFixedThreadPool

Definisi:
xecutorService executorService=Executors.newFixedThreadPool(2);>

Kelemahan: Barisan gilir penyekat senarai terpaut LinkBlockQueue digunakan Apabila kelajuan pengumpulan tugas lebih besar daripada kelajuan pemprosesan, tugasan mudah terkumpul dan menyebabkan limpahan memori OOM

<.>

newSingleThreadExecutor

Definisi: ExecutorService executorService =Executors.newSingleThreadExecutor();>

Kod di atas adalah serupa FixedThreadPoop(1) baharu, tetapi terdapat perbezaan, kerana terdapat lapisan tambahan FinalizableDelegatedExecutorService di luar, fungsinya:

Ia boleh dapat dilihat bahawa intipati fixedExecutorService ialah ThreadPoolExecutor, jadi fixedExecutorService boleh dipaksa masuk ke ThreadPoolExecutor, tetapi singleExecutorService tidak ada kena mengena dengan ThreadPoolExecutor, jadi pemindahan paksa gagal Oleh itu, selepas newSingleThreadExecutor, parameternya tidak boleh disatukan () modified. dan ia benar-benar satu utas.

Kelemahan: Baris gilir menyekat senarai terpaut LinkBlockQueue digunakan Apabila kelajuan pengumpulan tugas lebih besar daripada kelajuan pemprosesan, tugasan mudah terkumpul dan menyebabkan limpahan memori OOM

newCacheThreadPool

Definisi: ExecutorService executorService=Executors.newCacheThreadPool();

Kelemahan: SynchronousQueue ialah pelaksanaan Blocking queue. bilangan maksimum utas ialah Integer.MAX_VALUE, jadi apabila terdapat terlalu banyak utas, memori OOM mudah melimpah

ScheduledThreadPool

Definisi: ExecutorService executorService=Executors.neh 2);

Apakah parameter penting kumpulan benang?

Kaedah pembinaan ThreadPoolExecutor adalah seperti berikut:

源码：
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
        //ScheduledThreadPoolExecutor继承ThreadPoolExecutor
        return new ScheduledThreadPoolExecutor(corePoolSize);
    }
    
public ScheduledThreadPoolExecutor(int corePoolSize) {
    //ScheduledThreadPoolExecutor继承ThreadPoolExecutor，故super()会调用ThreadPoolExecutor的构造函数初始化并返回一个ThreadPoolExecutor，而ThreadPoolExecutor使实现ExecutorService接口的
    //最终ScheduledThreadPoolExecutor也和上面几种线程池一样返回的是ExecutorService接口的实现类ThreadPoolExecutor
    super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
          new DelayedWorkQueue());
}

keepAliveTime merujuk kepada bilangan semasa benang dalam [teras Bilangan utas, bilangan maksimum utas] Berapa lama benang bukan teras ini menunggu masa melahu tanpa sebarang kerja sebelum keluar dari kumpulan utas; baris gilir menunggu dan bilangan maksimum utas Ia tidak ada kaitan dengannya Keutamaan penciptaan utas = utas teras > daripada benang)

Jika teras Bilangan utas ialah 5, panjang baris gilir menunggu ialah 3, dan bilangan maksimum utas ialah 10: Apabila bilangan utas terus meningkat, 5 utas teras dibuat terlebih dahulu Apabila bilangan utas teras penuh, utas dibuang ke baris gilir menunggu Apabila baris gilir menunggu penuh (3 utas), bilangan maksimum utas akan dibandingkan pada masa ini (anda boleh hanya muncul selepas menunggu bilangan maksimum utas diisi), dan anda boleh terus membuat 2 utas (5+3+2 Jika bilangan utas melebihi bilangan maksimum utas, maka Laksanakan dasar penolakan; 🎜>

• Jika bilangan utas teras ialah 5, panjang baris gilir menunggu ialah 3, dan bilangan maksimum utas ialah 7: Apabila bilangan utas terus bertambah, buat 5 utas teras dahulu . Apabila nombor penuh, utas dilemparkan ke dalam baris gilir menunggu Apabila terdapat 2 utas dalam baris gilir menunggu, bilangan maksimum utas dicapai (5+2=7), tetapi baris gilir menunggu belum penuh, jadi tidak perlu risau tentang bilangan maksimum utas sehingga menunggu Apabila baris gilir penuh (3 utas yang disekat), bilangan maksimum utas akan dibandingkan pada masa ini (bilangan maksimum utas hanya boleh keluar selepas menunggu. untuk baris gilir penuh). .

如何自定义线程池

可以使用有界队列，自定义线程创建工厂ThreadFactory和拒绝策略handler来自定义线程池

public class ThreadTest {
    public static void main(String[] args) throws InterruptedException, IOException {
        int corePoolSize = 2;
        int maximumPoolSize = 4;
        long keepAliveTime = 10;
        TimeUnit unit = TimeUnit.SECONDS;
        BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(2);
        ThreadFactory threadFactory = new NameTreadFactory();
        RejectedExecutionHandler handler = new MyIgnorePolicy();
       ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit,
                workQueue, threadFactory, handler);
        executor.prestartAllCoreThreads(); // 预启动所有核心线程        
        for (int i = 1; i <= 10; i++) {
            MyTask task = new MyTask(String.valueOf(i));
            executor.execute(task);
        }
        System.in.read(); //阻塞主线程
    }
    static class NameTreadFactory implements ThreadFactory {
        private final AtomicInteger mThreadNum = new AtomicInteger(1);
        @Override
        public Thread newThread(Runnable r) {
            Thread t = new Thread(r, "my-thread-" + mThreadNum.getAndIncrement());
            System.out.println(t.getName() + " has been created");
            return t;
        }
    }

    public static class MyIgnorePolicy implements RejectedExecutionHandler {
        @Override
        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
            doLog(r, e);
        }
        private void doLog(Runnable r, ThreadPoolExecutor e) {
            // 可做日志记录等
            System.err.println( r.toString() + " rejected");
//          System.out.println("completedTaskCount: " + e.getCompletedTaskCount());
        }
    }

    static class MyTask implements Runnable {
        private String name;
        public MyTask(String name) {
            this.name = name;
        }
        @Override
        public void run() {
            try {
                System.out.println(this.toString() + " is running!");
                Thread.sleep(3000); //让任务执行慢点
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        public String getName() {
            return name;
        }
        @Override
        public String toString() {
            return "MyTask [name=" + name + "]";
        }
    }
}

运行结果：

其中7-10号线程被拒绝策略拒绝了，1、2号线程执行完后，3、6号线程进入核心线程池执行，此时4、5号线程在任务队列等待执行，3、6线程执行完再通知4、5线程执行

Atas ialah kandungan terperinci Apakah empat kumpulan benang yang disertakan dengan Java?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!