#NEWLINE# def desireNumberOfWorkers( self , count , blocking = False ) : #NEWLINE# #INDENT# logging . info ( 'desiring %d workers' , count ) #NEWLINE# self . desired = count #NEWLINE# delta = ( count - len ( self . threads ) ) #NEWLINE# if ( delta > 0 ) : #NEWLINE# #INDENT# self . _addWorkers ( delta ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( delta < 0 ) : #NEWLINE# #INDENT# self . _removeWorkers ( ( - count ) )