#NEWLINE# def _repopulate_pool( self ) : #NEWLINE# #INDENT# 'Bring the number of pool processes up to the specified number,\n        for use after reaping workers which have exited.\n        ' #NEWLINE# for i in range ( ( self . _processes - len ( self . _pool ) ) ) : #NEWLINE# #INDENT# w = self . Process ( target = worker , args = ( self . _inqueue , self . _outqueue , self . _initializer , self . _initargs , self . _maxtasksperchild ) ) #NEWLINE# self . _pool . append ( w ) #NEWLINE# w . name = w . name . replace ( 'Process' , 'PoolWorker' ) #NEWLINE# w . daemon = True #NEWLINE# w . start ( ) #NEWLINE# debug ( 'added worker' )