void function ( ) { log . info ( "srini_string" + taskHolderDelayQueue . size ( ) ) ; for ( TaskProcessor loc0 : taskProcessorQueue ) { loc0 . deactivate ( ) ; } taskProcessorQueue . clear ( ) ; }
stop processing the tasks concode_field_sep int workerCount concode_elem_sep Log log concode_elem_sep T task concode_elem_sep long idleTaskDelayMillis concode_elem_sep ExecutorService taskUpdateExecutorService concode_elem_sep TaskExceptionHandler taskExceptionHandler concode_elem_sep DelayQueue<TaskHolder> taskHolderDelayQueue concode_elem_sep Map<String,TaskHolder<T>> taskHolderRegistry concode_elem_sep String id concode_elem_sep ExecutorService taskExecutorPool concode_elem_sep Queue<TaskProcessor> taskProcessorQueue concode_elem_sep Log log concode_field_sep void add concode_elem_sep void handleException concode_elem_sep void setExceptionHandler concode_elem_sep void start concode_elem_sep void run concode_elem_sep void run concode_elem_sep void remove concode_elem_sep T getTask