#!/usr/bin/env python

from multiprocessing.managers import BaseManager

import numpy as np

import interp.bootstrap

class QueueManager(BaseManager): pass
QueueManager.register('get_inqueue' )

m = QueueManager(address=('gannon', 50000), authkey='asdf')
m.connect()

if __name__ == '__main__':
  inq = m.get_inqueue()

  for i in xrange(1000):
    X = np.random.random((1,3))[0]
    inq.put((i,X))