method: execnet.SocketGateway.thread_executor

 worker thread to execute source objects from the execution queue. 

    def thread_executor(self, channel, (source, outid, errid)):

origin: Gateway

where:

• self :: <UNKNOWN>
• channel :: <UNKNOWN>
• .4 :: <UNKNOWN>
• return value :: <UNKNOWN>

function source:

def thread_executor(self, channel, (source, outid, errid)):
    """ worker thread to execute source objects from the execution queue. """
    from sys import exc_info
    try:
        loc = { 'channel' : channel }
        self.trace("execution starts:", repr(source)[:50])
        close = self._local_redirect_thread_output(outid, errid) 
        try:
            co = compile(source+'\n', '', 'exec',
                         __future__.CO_GENERATOR_ALLOWED)
            exec co in loc
        finally:
            close() 
            self.trace("execution finished:", repr(source)[:50])
    except (KeyboardInterrupt, SystemExit):
        raise
    except:
        excinfo = exc_info()
        l = traceback.format_exception(*excinfo)
        errortext = "".join(l)
        channel.close(errortext)
        self.trace(errortext)
    else:
        channel.close()