java中如何使用線程池

本篇文章給大家分享的是有關java中如何使用線程池，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler) {
        if (corePoolSize < 0 ||
            maximumPoolSize <= 0 ||
            maximumPoolSize < corePoolSize ||
            keepAliveTime < 0)
            throw new IllegalArgumentException();
        if (workQueue == null || threadFactory == null || handler == null)
            throw new NullPointerException();
        this.acc = System.getSecurityManager() == null ?
                null :
                AccessController.getContext();
        this.corePoolSize = corePoolSize;
        this.maximumPoolSize = maximumPoolSize;
        this.workQueue = workQueue;
        this.keepAliveTime = unit.toNanos(keepAliveTime);
        this.threadFactory = threadFactory;
        this.handler = handler;
    }
	
	構造函數的參數含義如下：

corePoolSize:指定了線程池中的線程數量，它的數量決定了添加的任務是開辟新的線程去執行，還是放到workQueue任務隊列中去；

maximumPoolSize:指定了線程池中的最大線程數量，這個參數會根據你使用的workQueue任務隊列的類型，決定線程池會開辟的最大線程數量；

keepAliveTime:當線程池中空閑線程數量超過corePoolSize時，多余的線程會在多長時間內被銷毀；

unit:keepAliveTime的單位

workQueue:任務隊列，被添加到線程池中，但尚未被執行的任務；它一般分為直接提交隊列、有界任務隊列、無界任務隊列、優先任務隊列幾種；

threadFactory:線程工廠，用于創建線程，一般用默認即可；

handler:拒絕策略；當任務太多來不及處理時，如何拒絕任務；

package com.test;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class TestThreadPool {

	public static void main(String[] args) {
		/**
		 * 線程數量
		 * 最大數量 超標后會進入隊列、隊列超標后觸發策略
		 * 
		 * ArrayBlockingQueue 有界隊列
		 * LinkedBlockingQueue 無界隊列
		 * SynchronousQueue 同步隊列
		 * 
		 * 執行線程超標策略 RejectedExecutionHandler
		 * ThreadPoolExecutor.AbortPolicy:丟棄任務并拋出RejectedExecutionException異常。 
		 * ThreadPoolExecutor.DiscardPolicy：也是丟棄任務，但是不拋出異常。 
		 * ThreadPoolExecutor.DiscardOldestPolicy：丟棄隊列最前面的任務，然后重新嘗試執行任務（重復此過程）
		 * ThreadPoolExecutor.CallerRunsPolicy：由調用線程處理該任務
		 * 自定義
		 * Executors.newCachedThreadPool();        //創建一個緩沖池，緩沖池容量大小為Integer.MAX_VALUE
		 * Executors.newSingleThreadExecutor();   //創建容量為1的緩沖池
		 * Executors.newFixedThreadPool(int);    //創建固定容量大小的緩沖池
		 *
		 */
		ThreadPoolExecutor pool=new ThreadPoolExecutor(5, 5, 1, TimeUnit.SECONDS, new ArrayBlockingQueue(2),new RejectedExecutionHandler() {
			@Override
			public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
			 System.out.println(r+"丟棄了");
			}
		});
		
		for(int i=0;i<7;i++) {
			Runnable run=new TestThread(i);
			pool.execute(run);
		}
		//pool.shutdown();
	}
}

class TestThread implements Runnable {
	private int i;
	
	public TestThread(int i) {
		this.i=i;
	}
	
	@Override
	public void run() {
		try {
			Thread.sleep(100);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println(Thread.currentThread().getName()+" "+i);
	}
}

以上就是java中如何使用線程池，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。