#NEWLINE# def _readQueue( thread_id = None ) : #NEWLINE# #INDENT# global oscThreads #NEWLINE# thread = oscThreads [ thread_id ] #NEWLINE# try : #NEWLINE# #INDENT# while True : #NEWLINE# #INDENT# message = thread . queue . get_nowait ( ) #NEWLINE# thread . addressManager . handle ( message ) #NEWLINE# #UNINDENT# #UNINDENT# except : #NEWLINE# #INDENT# pass