#NEWLINE# def _setup_queues( self ) : #NEWLINE# #INDENT# context = getattr ( self , '_ctx' , mp ) #NEWLINE# self . _inqueue = CustomizablePicklingQueue ( context , self . _forward_reducers ) #NEWLINE# self . _outqueue = CustomizablePicklingQueue ( context , self . _backward_reducers ) #NEWLINE# self . _quick_put = self . _inqueue . _send #NEWLINE# self . _quick_get = self . _outqueue . _recv