void function ( Runnable arg0 ) { synchronized ( internalLock ) { queue . add ( arg0 ) ; } startQueueWorker ( ) ; }
adds a task to the queue and makes sure a worker thread is running , unless the queue has been suspended . if this method throws , e.g. a rejectedexecutionexception from the delegate executor , execution of tasks will stop until a call to this method or to #resume is made . concode_field_sep boolean isWorkerRunning concode_elem_sep Deque<Runnable> queue concode_elem_sep Executor executor concode_elem_sep Object internalLock concode_elem_sep int suspensions concode_elem_sep Logger log concode_field_sep void suspend concode_elem_sep void resume concode_elem_sep void executeFirst concode_elem_sep void startQueueWorker concode_elem_sep void run concode_elem_sep void workOnQueue