#NEWLINE# def maybe_start( self ) : #NEWLINE# #INDENT# should_start = False #NEWLINE# did_acquire = False #NEWLINE# try : #NEWLINE# #INDENT# did_acquire = self . _loop_lock . acquire ( False ) #NEWLINE# if ( did_acquire and ( not self . _started ) ) : #NEWLINE# #INDENT# self . _started = True #NEWLINE# should_start = True #NEWLINE# #UNINDENT# #UNINDENT# finally : #NEWLINE# #INDENT# if did_acquire : #NEWLINE# #INDENT# self . _loop_lock . release ( ) #NEWLINE# #UNINDENT# #UNINDENT# if should_start : #NEWLINE# #INDENT# self . _thread = Thread ( target = self . _run_loop , name = 'cassandra_driver_event_loop' ) #NEWLINE# self . _thread . daemon = True #NEWLINE# self . _thread . start ( )