diff --git a/bin/results.py b/bin/results.py new file mode 100644 index 0000000..a647756 --- /dev/null +++ b/bin/results.py @@ -0,0 +1,19 @@ +#!/usr/bin/env python + +from multiprocessing.managers import BaseManager + +import numpy as np + +import interp.bootstrap + +class QueueManager(BaseManager): pass +QueueManager.register('get_outqueue') + +m = QueueManager(address=('gannon', 50000), authkey='asdf') +m.connect() + +if __name__ == '__main__': + outq = m.get_outqueue() + + while True: + print outq.get()