| | |
|---|
| | | return this.threadPool; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /**循环校验队列数量模式，针对最大的队列，返回true就是可以加入队列 |
|---|
| | | * 避免死循环，设置了循环校验次数 |
|---|
| | | * @param sleepMillisecond 睡眠，毫秒秒,如果是空的，那么直接返回 |
|---|
| | | * @param frequency 循环校验次数，空值默认100次数 |
|---|
| | | * @return 最后都是返回true |
|---|
| | | */ |
|---|
| | | public boolean whileCheckQueue(Integer sleepMillisecond,Integer frequency){ |
|---|
| | | if(frequency == null){ |
|---|
| | | frequency = 100; |
|---|
| | | } |
|---|
| | | while (frequency>0){ |
|---|
| | | if(!noRund(sleepMillisecond)){ |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | frequency--; |
|---|
| | | } |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /**针对最大的队列，如果没有超过返回是false的，超过就返回是true的 |
|---|
| | | * 单返回true的时候，就不要传入队列了 |
|---|
| | | * @param sleepMillisecond 睡眠，毫秒秒,如果是空的，那么直接返回 |
|---|
