#NEWLINE# def __init__( self , max_migrants = 1 ) : #NEWLINE# #INDENT# self . max_migrants = max_migrants #NEWLINE# self . migrants = multiprocessing . Queue ( self . max_migrants ) #NEWLINE# self . _lock = multiprocessing . Lock ( ) #NEWLINE# self . __name__ = self . __class__ . __name__