pprocess

tests/start_loop.py

159:448313b5b34e
2009-06-05 Paul Boddie Added more documentation about continuous communications.
     1 #!/usr/bin/env python     2      3 from pprocess import start     4      5 def loop(channel, limit):     6     print "loop to", limit     7     i = channel.receive()     8     while i < limit:     9         print i    10         i = channel.receive()    11     channel.send("Done")    12     13 if __name__ == "__main__":    14     limit = 100    15     channel = start(loop, limit)    16     for i in range(0, limit + 1):    17         channel.send(i)    18     print channel.receive()    19     20 # vim: tabstop=4 expandtab shiftwidth=4