Java怎么固定大小的線程池

這篇文章給大家分享的是有關Java怎么固定大小的線程池的內容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

1.固定大小的線程池簡介

線程池就是在程序啟動的時候先建立幾個可以使用的線程放在那里，然后等著具體的任務放進去，這個任務基本可以說都是Runnable的實現類，因此它減小了系統每次新建和銷毀線程的開銷，但同時增加了維護這些線程的開銷，個中取舍看具體情況而定。

固定大小的線程池就是在啟動的時候創建了固定個數的線程放在那里等待使用。

2.包裝一個線程池對象

public class TaskPool{
    private final ThreadPoolExecutor executor = (ThreadPoolExecutor)Executors.newFixedThreadPool(9); // 創建一個大小為9的固定線程池，可以按照CPU的核數初步判定，如果CPU密集性任務則創建N+1個，如果是IO密集型任務則創建2N+1個，其中N即CPU的核數
    protected void shutdown(){
        // do something
        // 這個方法等待線程池中所有已提交任務執行結束，不接收新任務，然后結束
        executor.shutdown(); 
        // 這個強制結束所有任務，然后正在等在的任務列表
        // executor.shutdownNow(); 
    }
    protected void execute(Runnable command){
        // do something
        // 提交任務
        executor.execute(command); 
    }
    public void status(){
        StringBuffer sb = new StringBuffer();
        // 當前正在執行任務的線程數
        sb.append(executor.getActiveCount() + "\n"); 
        // 當前正在等待執行的線程數
        sb.append(executor.getQueue().size() + "\n"); 
        // 返回已經完成的線程數
        sb.append(executor.getCompletedTaskCount() + "\n"); 
        System.out.println(sb.toString());
        // 注：以上方法都是返回一個大概值，因為線程在執行中，這些狀態隨時都會改變
    }
}

3.使用線程池

public class Launcher{
    private TaskPool taskPool = new TaskPool();
    public static void main(String[] args){
        // 新建100個任務，Runnable的實現類Task
        Task[] tasks = new Task[100];
        for (int i = 0; i < tasks.length; i++){
            tasks[i] = new Task("Task " + (i+1));
            // 提交到線程池運行
            taskPool.execute(task[i]);
            if ( i % 50 == 0){
                taskPool.status();
        } 
    }
    private static class Task implements Runnable{
        private String name;
        public Task(String name){
            this.name = name;
        }
        public void run(){
            // do something
            System.out.println("我的名字是：" + this.name);
        }
    }
}

Java線程池小拓展

線程池的介紹

1 常用的 池化技術

C3P0

DBCP

2 線程池的衍生

頻繁的創建線程對象和多線程之間進行上下文切換,是非常耗時間和資源的所以JDK1.5中提出了線程池技術

3 使用線程池

Exector

4 線程池的創建

創建一個固定大小的線程池 ( 最常用的方法 )

ExecutorService pool = Executors.newFixedThreadPool(2);
Runnable task = new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName());
}
}
};
pool.execute(task);
pool.execute(task);
pool.execute(task);//線程池的帶下只有兩個 現在這個任務在其等待隊列中排隊等候

創建可變大小的線程池

ExecutorService pool = Executors.newCachedThreadPool();
Runnable task = new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName());
}
}
};
pool.execute(task);
pool.execute(task);
pool.execute(task);

創建獨立任務的線程池

ExecutorService pool = Executors.newSingleThreadExecutor();
Runnable task = new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName());
}
}
};
pool.execute(task);
pool.execute(task);
pool.execute(task);

創建可調度的線程池

ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(2);
Runnable task = new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName());
}
}
};
threadPool.schedule(task, 2000, TimeUnit.MILLISECONDS);

感謝各位的閱讀！關于“Java怎么固定大小的線程池”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！