#NEWLINE# def _consume( self ) : #NEWLINE# #INDENT# ' Main loop for each thread, handles picking a task off the\n        queue, processing it and notifying the queue that it is done.\n        ' #NEWLINE# while True : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# ( task , args , kwargs ) = self . queue . get ( True ) #NEWLINE# task ( * kwargs , ** kwargs ) #NEWLINE# #UNINDENT# finally : #NEWLINE# #INDENT# self . queue . task_done ( )