往線程池中動態添加任務示例

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPoolDynamicTasks extends Thread {

    private BlockingQueue<Runnable> bq = new LinkedBlockingQueue<>();// 可將此隊列注入到客戶端的子模塊中
    private ExecutorService es = new ThreadPoolExecutor(2, 4, 0, TimeUnit.SECONDS, bq);

    private void init() {
        try {
            bq.put(new Runnable() {

                @Override
                public void run() {
                    while (true) {
                        try {
                            Thread.sleep(3000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        System.out.println("添加的任務");
                    }
                }
            });
            bq.put(new Runnable() {

                @Override
                public void run() {
                    // while (true) {
                    try {
                        Thread.sleep(3000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("AAAAAA");
                    // }
                }
            });
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        ThreadPoolDynamicTasks instance = new ThreadPoolDynamicTasks();
        instance.init();// 阻塞隊列中添加任務
        instance.start();// 利用線程循環遍歷阻塞隊列，每執行一個任務就移除一個任務
        instance.getTaskLengSize();// 獲取阻塞隊列里的任務數量
        try {
            Thread.sleep(3000);
            instance.addTask();// 在main線程中中途添加阻塞隊列
            instance.getTaskLengSize();// 獲取阻塞隊列里的任務數量
            Thread.sleep(1000);
            instance.getTaskLengSize();// 獲取阻塞隊列的任務數量
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }

    @Override
    public void run() {
        while (true) {
            for (Runnable runnable : bq) {
                // try {
                // bq.take();
                // } catch (InterruptedException e) {
                // e.printStackTrace();
                // }
                es.execute(runnable);
                bq.remove(runnable);
            }
        }
    }

    private void addTask() {
        try {
            bq.put(new Runnable() {

                @Override
                public void run() {
                    while (true) {
                        try {
                            Thread.sleep(3000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        System.out.println("~~~~~~~~~~~");
                    }
                }
            });
            // es.execute(command);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    private void getTaskLengSize() {
        System.out.println(bq.size());
    }

}

　　只要將任務隊列注冊到上下文容器中(例如web應用的servletContext、Eclipse應用的EclipseContext)，注冊到需要執行任務的java文件里，就可以用一個線程池執行所有的任務。