自定义线程池

package com.snow.junit;

import java.util.LinkedList;

public class MyThreadPool extends ThreadGroup{
    private boolean isClose = false;  //线程池是否关闭
    private LinkedList workQueue;     //工作队列
    private static int threadPollID = 1;  //线程池ID
    
    public MyThreadPool(int poolSize) {
        super("threadPoolId" + "");      //调用父类构造方法，指定ThreadGroup的名称
        setDaemon(true);                 //继承的方法，设置是否设置守护线程池
        workQueue = new LinkedList();     //创建工作队列
        for (int i = 0; i < poolSize; i++) {
            new WorkThread(i).start();    //创建并启动工作线程，创建线程池最大容量数的工作线程
        }
    }
    
    //向工作线程中添加一个任务，由工作线程来执行该任务
    public synchronized void execute(Runnable task){
        if (isClose) {
            throw new IllegalStateException();
        }
        if (task != null) {
            workQueue.add(task);    //向消息队列中添加一个任务
            notify();               //唤醒一个正在getTask()方法中等待任务的工作线程
        }
    }
    
    //从工作队列中取出一个任务，工作线程会调用该方法