#NEWLINE# def run( self ) : #NEWLINE# #INDENT# self . _logger . debug ( 'Thread started' ) #NEWLINE# self . __semaphore . release ( ) #NEWLINE# while ( not self . __stop ) : #NEWLINE# #INDENT# events = self . __proactor . select ( 0.01 ) #NEWLINE# if events : #NEWLINE# #INDENT# self . _logger . debug ( 'Got events from poll: {}' . format ( events ) ) #NEWLINE# self . __sig_events . emit ( self ) #NEWLINE# #UNINDENT# #UNINDENT# self . _logger . debug ( 'Exiting thread' )