~chromakode/boots/nodes-async

« back to all changes in this revision

Viewing changes to src/boots/lib/lingos/external.py

Committer: David Rosenbaum
Date: 2010-02-08 19:08:53 UTC
mfrom: (56.1.1 boots)
Revision ID: davidjrosenbaum@comcast.net-20100208190853-3hqambih3blnm37z

Merge in updated external lingo code.

files modified:
src/boots/lib/lingos/external.py

Show diffs side-by-side

added added

removed removed

src/boots/lib/lingos/external.py

def __init__(self, executable, executable_args, *args, **kwargs):

"""Create a new interpreter using the specified executable with the specified arguments."""

super(ExternalInterpreter, self).__init__(*args, **kwargs)

self.interpreter = subprocess.Popen(executable, *executable_args, stdin = subprocess.PIPE, stdout = subprocess.PIPE, stderr = subprocess.STDOUT)

# Since self.interpreter.stdout.readline could block, a thread is used to read the output.

self.read_thread = threading.Thread(target = self._readlines)

self.read_thread.start()

self.output_lines = []

self.lock = threading.RLock()

self.executable = executable

self.executable_args = executable_args

self.interpreter = None

def _readlines(self):

while True:

def evaluate(self, code):

"""Evaluate code using the external interpreter. All return values are strings."""

# The maximum amount of time to wait for output.

# FIXME: This is a kludge and should be fixed if possible.

if self.interpreter == None:

self.interpreter = subprocess.Popen(self.executable, *self.executable_args, stdin = subprocess.PIPE, stdout = subprocess.PIPE, stderr = subprocess.STDOUT)