private void processLoop ( ) { while ( true ) { try { this . queue . pop ( this . processFunc ) ; } catch ( InterruptedException t ) { log . error ( "DefaultController#processLoop get interrupted {}" , t . getMessage ( ) , t ) ; } } }
processLoop drains the work queue .