def __init__(self, fd_r, fd_w):
        """
        \param r,w The read-write file descriptors used for this endpoint
        """
        self._fd_r  = fd_r
        self._fd_w  = fd_w
        self._wlock = threading.Lock() # send() has to be thread-safe

        \param r,w The read-write file descriptors used for this endpoint
        
recipes/Python/576520_Multithreaded_MultiplexerDemultiplexer_allow/recipe-576520.py