public static BlockingQueue < Runnable > getThreadQueue ( ExecutorService executorService ) { if ( executorService instanceof ThreadPoolExecutor ) return ( ( ThreadPoolExecutor ) executorService ) . getQueue ( ) ; throw JMExceptionManager . handleExceptionAndReturnRuntimeEx ( log , new IllegalArgumentException ( "Unsupported ExecutorService - Use ThrJMThread.newThreadPool Or newSingleThreadPool To Get ExecutorService !!!" ) , "getThreadQueue" , executorService ) ; }
Gets thread queue .