#NEWLINE# def join( self , * args , **kwargs ) : #NEWLINE# #INDENT# 'Inform the thread to shut down.' #NEWLINE# if self . _running : #NEWLINE# #INDENT# with self . _lock : #NEWLINE# #INDENT# self . _queue . put ( _NULL ) #NEWLINE# self . _queue . join ( ) #NEWLINE# super ( ) . join ( * args , ** kwargs )