#NEWLINE# def start( self ) : #NEWLINE# #INDENT# self . io_thread . start ( ) #NEWLINE# self . print_thread . start ( ) #NEWLINE# LOGGER . debug ( 'Using a threadpool size of: %s' , self . num_threads ) #NEWLINE# for i in range ( self . num_threads ) : #NEWLINE# #INDENT# worker = Worker ( queue = self . queue ) #NEWLINE# worker . setDaemon ( True ) #NEWLINE# self . threads_list . append ( worker ) #NEWLINE# worker . start ( )