| | |
|---|
| | | */ |
|---|
| | | public interface Pool{ |
|---|
| | | /** |
|---|
| | | * 把所要执行的工作对象实例放入线程池中 |
|---|
| | | * @param job ThreadJob 工作对象实例 |
|---|
| | | * @throws Exception |
|---|
| | | * 线程池中线程个数 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public Integer size() ; |
|---|
| | | /** |
|---|
| | | * 线程池中线程最大限制个数 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public Integer maxThread() ; |
|---|
| | | /** |
|---|
| | | * 线程池中线程最小限制个数 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public Integer minThread() ; |
|---|
| | | /** |
|---|
| | | * 把所要执行的工作任务对象实例放入线程池中 |
|---|
| | | * @param job ThreadJob 工作任务对象实例 |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | public void putJob(Job job) throws Exception ; |
|---|
| | | } |
|---|
| | |
|---|
| | | */ |
|---|
| | | public interface Job{ |
|---|
| | | /** |
|---|
| | | * 线程池工作类的回调方法。 |
|---|
| | | * 线程池线程执行时的回调方法。 |
|---|
| | | * 注意： |
|---|
| | | * 1、这个方法内，尽量不使用try catch语句，如果确实需要用， |
|---|
| | | * 要一定用try catch finnaly语句，而且finnaly内不要 |
|---|
| | | * 再有可能产生异常。否则线程得不到结束，不能回归空闲线程池。 |
|---|
| | | * 2、如果在短线程池中，这个方法内不能执行永循环工作，例如有while(true)这样 |
|---|
| | | * 的工作任务，否则至超时时间，系统强制停止此工作。 |
|---|
| | | * 3、如果在短线程池中，这个方法内只能执行短时间即成完成的工作，工作完成后即退出本方法体。 |
|---|
| | | * 要一定用try catch finnaly语句，而且finnaly内不要再有可能产生异常。 |
|---|
| | | * 否则线程得不到结束，不能回归空闲线程池。 |
|---|
| | | * 2、如果在短线程池中，这个方法内不能执行永循环工作，例如有while(true)这样的工作任务， |
|---|
| | | * 否则至超时时间，系统强制停止此工作。 |
|---|
| | | * 3、如果在短线程池中，这个方法内只能执行短时间即可完成的工作，工作完成后即退出本方法体。 |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | public void execute() throws Exception ; |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 外部调用，强制销毁工作 |
|---|
| | | * 主要应用： |
|---|
| | |
|---|
| | | * public void destroy(){ |
|---|
| | | * this.isDestroy = true ; |
|---|
| | | * } |
|---|
| | | * |
|---|
| | | * 当然有while(true){}死循环的工作job一定在长线程池中工作，如果在短线程池中工作，线程池监控线程就会 |
|---|
| | | * |
|---|
| | | * 需要while(true){}死循环的工作job一定在长线程池中工作，如果在短线程池中工作，线程池监控线程就会 |
|---|
| | | * 以忙碌超时原因把线程强制销毁（线程池监控线程调用工作线程的destroy方法），这里的销毁实际上销毁不了 |
|---|
| | | * 的，只不把该线程清了线程池，这个线程仍然是活着的， 线程里的job仍然被执行，所以在线程的destroy方法 |
|---|
| | | * 中调用了job.destroy()，使job停止下来，线程也自然执行完毕而得以停止，以上是代码逻辑存在while(true){} |
|---|
| | | * 死循环，如果不是代码逻辑，而是程序bug造成的死循环，或程序抛出了异常且未抓住异常，这时无论如何也停止 |
|---|
| | | * 线程，这个线程仍然是活着的， 线程里的job仍然被执行，所以在线程的destroy方法中调用了job.destroy()， |
|---|
| | | * 使job停止下来，线程也自然执行完毕而得以停止，以上是代码逻辑存在while(true){}死循环， |
|---|
| | | * 如果不是代码逻辑，而是程序bug造成的死循环，或程序抛出了异常且未捕获异常，这时无论如何也停止 |
|---|
| | | * 不了工作job，也销毁不了这个线程的 |
|---|
| | | */ |
|---|
| | | public void destroy() ; |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 判断，工作是否被外部强制销毁，销毁后，持有本job的线程就能施放回归 |
|---|
| | | */ |
|---|
