#NEWLINE# def run( self ) : #NEWLINE# #INDENT# 'Start processing jobs in the queue. You should not need\n    to call this as ``add_task`` automatically starts the queue.\n    Processing threads will stop when there are no jobs available\n    in the queue for at least ``idle_timeout`` seconds.\n    ' #NEWLINE# with self . condition : #NEWLINE# #INDENT# if ( len ( self . threads ) >= self . thread_count ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# thread = self . __TaskLoop ( self ) #NEWLINE# self . threads . add ( thread ) #NEWLINE# thread . start ( )