diff --git a/bin/interactq.py b/bin/interactq.py deleted file mode 100644 index 92facb1..0000000 --- a/bin/interactq.py +++ /dev/null @@ -1,21 +0,0 @@ -import interp.bootstrap -from multiprocessing.managers import BaseManager -class QueueManager(BaseManager): pass -QueueManager.register('get_inqueue' ) -QueueManager.register('get_outqueue') -m = QueueManager(address=('localhost', 6666), authkey='asdf') -m.connect() -m.get_outqueue() -oq = m.get_outqueue() -iq = m.get_inqueue() - -import time -import numpy as np -s = time.time() - -for i in xrange(int(1e6)): - a = i - X = np.random.random((1,3))[0] - iq.put((i,5,128,X)) - -e = time.time()