public synchronized boolean submit ( I input ) throws InterruptedException { if ( termination || isInterrupted ( ) ) return false ; buffer_ . put ( input ) ; return true ; }
Submitting a new input for processing . Submitted input jobs are first buffered and then concurrently processed by workers . If the buffer is full the method blocks until new space is available .