2009-06-05 | Paul Boddie | raw annotate files changeset graph | Added support for continuous communications in the Exchange class, tidying various methods and adding new methods for monitoring the state of active channels and waiting tasks. Added a timeout method to the Exchange.store method. Added an example of timeouts and continuous communications. Updated release notes and some of the documentation. |
1 #!/usr/bin/env python 2 3 from pprocess import create 4 5 limit = 100 6 channel = create() 7 if channel.pid == 0: 8 i = channel.receive() 9 while i < limit: 10 print i 11 i = channel.receive() 12 channel.send("Done") 13 else: 14 for i in range(0, limit + 1): 15 channel.send(i) 16 print channel.receive() 17 18 # vim: tabstop=4 expandtab shiftwidth=4