#NEWLINE# def __init__( self , shutdown_timeout = DEFAULT_TIMEOUT ) : #NEWLINE# #INDENT# self . _queue = Queue ( ( - 1 ) ) #NEWLINE# self . _lock = threading . Lock ( ) #NEWLINE# self . _thread = None #NEWLINE# self . _thread_for_pid = None #NEWLINE# self . options = { #NEWLINE# #INDENT# 'shutdown_timeout' : shutdown_timeout , #NEWLINE# #UNINDENT# } #NEWLINE# self . start ( )