废话少说，上代码

package com.sinosoft;import java.util.concurrent.*;/** * Created by xushuyi on 2017/4/9. */public class ThreadPoolQueue {    /**     * 定义线程池中最大的线程数量     */    private static final Integer THREADPOOLSIZE = 100;    /**     * 创建线程队列     */    private static final BlockingQueue
     
       QUEUE = new LinkedBlockingQueue
      
       ();    /**     * 创建线程池     */    protected static ExecutorService executorService = Executors.newFixedThreadPool(THREADPOOLSIZE);    /**     * 线程池任务调度执行     */    static {        executorService.execute(new Runnable() {            public void run() {                while (!Thread.currentThread().isInterrupted()) {                    Object[] task = null;                    try {                        task = QUEUE.take();                    } catch (Exception e) {                        e.printStackTrace();                    }                    System.out.println("执行任务结果：" + task[0]);                }            }        });    }    /**     * 线程池中添加执行任务     *     * @param task t     */    public void newTaskToThreadPool(Object[] task) {        QUEUE.offer(task);    }    public static void main(String[] args) {        ThreadPoolQueue queue = new ThreadPoolQueue();        Object[] task = null;        for (int i = 0; i < 10; i++) {            task = new Object[]{"xushuyi_" + i};            queue.newTaskToThreadPool(task);        }    }}
      
     

真正项目中，就不会再使用static来初始化任务，而是定义一个方法，比如：public void runnbaleInit（），那么在配置文件中需要将本方法注入到Bean中

例如：