#NEWLINE# def _make_methods( self ) : #NEWLINE# #INDENT# self . _recv = recv = self . _reader . recv #NEWLINE# ( racquire , rrelease ) = ( self . _rlock . acquire , self . _rlock . release ) #NEWLINE# def get( ) : #NEWLINE# #INDENT# racquire ( ) #NEWLINE# try : #NEWLINE# #INDENT# return recv ( ) #NEWLINE# #UNINDENT# finally : #NEWLINE# #INDENT# rrelease ( ) #NEWLINE# #UNINDENT# #UNINDENT# self . get = recv #NEWLINE# if self . _reducers : #NEWLINE# #INDENT# def send( obj ) : #NEWLINE# #INDENT# buffer = BytesIO ( ) #NEWLINE# CustomizablePickler ( buffer , self . _reducers ) . dump ( obj ) #NEWLINE# self . _writer . send_bytes ( buffer . getvalue ( ) ) #NEWLINE# #UNINDENT# self . _send = send #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . _send = send = self . _writer . send #NEWLINE# #UNINDENT# if ( self . _wlock is None ) : #NEWLINE# #INDENT# self . put = send #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# ( wlock_acquire , wlock_release ) = ( self . _wlock . acquire , self . _wlock . release ) #NEWLINE# def put( obj ) : #NEWLINE# #INDENT# wlock_acquire ( ) #NEWLINE# try : #NEWLINE# #INDENT# return send ( obj ) #NEWLINE# #UNINDENT# finally : #NEWLINE# #INDENT# wlock_release ( ) #NEWLINE# #UNINDENT# #UNINDENT# self . put = put