#NEWLINE# def start_job( self ) : #NEWLINE# #INDENT# over_task_limit = ( over_task_limit . task_queue_limit - len ( self . task_queue ) ) #NEWLINE# if getattr ( self , 'buffer_task' , None ) : #NEWLINE# #INDENT# self . push_buffer_task ( ) #NEWLINE# #UNINDENT# if ( over_task_limit <= 0 ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# while ( over_task_limit > 1 ) : #NEWLINE# #INDENT# if self . _stop : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# self . buffer_task = self . buffer_queue . pop ( timeout = ( - 1 ) ) #NEWLINE# if ( self . buffer_task is None ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# self . push_buffer_task ( ) #NEWLINE# self . buffer_task = None #NEWLINE# over_task_limit -= 1