线程--多线程线程池

package com.demo;
import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPool2 {
    public static void main(String[] args) {
        /**
         * 线程池数量
         */
        int corePoolSize = 10;
        /**
         * 最大线程池数
         */
        int maximumPoolSize = 100;
        //ExecutorService threadPool = new ThreadPoolExecutor(corePoolSize,maximumPoolSize, 30, TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>());
        ExecutorService threadPool =Executors.newFixedThreadPool(4);
        String dao = "dao";
        List<String> list = new LinkedList<String>();
        for (int i = 0; i < 10; i++) {
            list.add(i + "");
        }
        Task task = null;
        for (String str : list) {
            task = new Task(dao, str);
            threadPool.execute(task);
        }
        threadPool.shutdown();
    }
}
class Task implements Runnable {
    /**
     * 注入DAo
     */
    private String dao;
    /**
     * 注入BEAn
     */
    private String bean;
    public Task(String dao, String bean) {
        this.dao = dao;
        this.bean = bean;
    }
    public void run() {
        try {
            //TimeUnit.SECONDS.sleep(1);
            System.out.println("线程名称 :"+Thread.currentThread() +"--线程激活数量--"+Thread.activeCount()+"---");
            System.out.println(dao + "--插入到数据库中---" + bean);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}