多线程学习笔记

多线程学习笔记

1、监控线程

   
   private int     childThreadNum   = 0;   //子线程数量

    private int     childThreadLimit = 30;  //子线程最大并发数量

    private int     pauseTime        = 60000;   //线程暂停时间，单位毫秒
   
    private boolean threadFlag  = true; //线程控制开关,如果调用threadClose则线程关闭
    
    public void run()
   {
        //线程控制开关
        while (threadFlag)
        {

                //达到子线程限制数量
               while (childThreadNum == childThreadLimit)
                {
                    //则休眠，不发起新线程
                    this.threadSleep(pauseTime);
                }
                //否则发起新线程
                   TestThread testThread = new Thread(TestThread ).start();
                //将当前线程作为子线程的父线程
                testThread.setFatherThread(this);
         
        }
   }
    
    /**
     * 根据传入参数，线程暂停特定时间
     */
    private void threadSleep(int pauseTime)
    {
        try
        {
            Thread.sleep(pauseTime);
        }
        catch (InterruptedException e)
        {
            e.printStackTrace();
        }
    }

    /**
     * 线程停止方法
     */
    public void threadClose()
    {
        threadFlag = false;
    }

    /**
     * 同步操作，子线程数量减一
     */
    public void childThreadClose()
    {
        if (childThreadNum > 0)
        {
            childThreadNum--;
        }
    }

    public int getPauseTime()
    {
        return pauseTime;
    }

    public void setPauseTime(int pauseTime)
    {
        this.pauseTime = pauseTime;
    }

2、子线程

private FatherThread fatherThread;

记得正常完成任务和抛异常时都要关闭子线程

fatherThread.childThreadClose();

设置父线程

    public void setFatherThread(UserMailsListenerThread userMailsListenerThread)
    {
        this.fatherThread = userMailsListenerThread;
    }