distribute multi-process
Project description
How to use this package? see the following example from queueManager import queueManager qm = queueManager() qm.connect() #if no server is open,it will fail in seconds a = qm.read() #blocks, until something in the queue can be read. print(a) data = ‘test data’ qm.write(data)#write some data to the queue, notice that, the write and read queue are two different queues;
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
queueManager-0.1.1.tar.gz
(1.6 kB
view hashes)