| | |
| | | import com.dy.common.threadPool.TreadPoolFactory; |
| | | import com.dy.common.mw.UnitAdapterInterface; |
| | | import com.dy.common.mw.UnitInterface; |
| | | import com.dy.common.mw.UnitStartedCallbackInterface; |
| | | import com.dy.common.mw.UnitCallbackInterface; |
| | | |
| | | public class SupportUnit implements UnitInterface { |
| | | |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void start(UnitStartedCallbackInterface callback) throws Exception { |
| | | public void start(UnitCallbackInterface callback) throws Exception { |
| | | if(!started){ |
| | | started = true ; |
| | | if(confVo.enableShortThreadPool) { |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void stop(UnitStartedCallbackInterface callback) { |
| | | public void stop(UnitCallbackInterface callback) { |
| | | } |
| | | |
| | | /* |
| | |
| | | supVo.long_busyTimeout = -1 ; |
| | | } |
| | | |
| | | supVo.enableShortThreadPool = true ; |
| | | supVo.enableLongThreadPool = true ; |
| | | |
| | | supVo.enableThreadPool = true ; |
| | | |
| | | supVo.showStartInfo = true ; |
| | | |
| | | SupportUnit supUnit = SupportUnit.getInstance() ; |
| | |
| | | supUnit.start(obj -> { |
| | | }); |
| | | } |
| | | |
| | | private static class AdapterImp_SupportUnit implements SupportUnitAdapter { |
| | | |
| | | private SupportUnitConfigVo configVo = null ; |