#NEWLINE# def get_change_event_collector( self , thread_name ) : #NEWLINE# #INDENT# ' Return the dedicated RecordContainer for the thread.\n\n        If no RecordContainer is found for `thread_name` then a new\n        RecordContainer is created.\n\n        ' #NEWLINE# with self . _creation_lock : #NEWLINE# #INDENT# container = self . _record_containers . get ( thread_name ) #NEWLINE# if ( container is None ) : #NEWLINE# #INDENT# container = RecordContainer ( ) #NEWLINE# self . _record_containers [ container ] = container #NEWLINE# #UNINDENT# return container