1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
import threading
from random import randint
from time import sleep, ctime
from Queue import Queue
class MyThread(threading.Thread):
def __init__(self, func, args, name = ''):
threading.Thread.__init__(self)
self.name = name
self.func = func
self.args = args
def getResult(self):
return self.res
def run(self):
print'starting', self.name, 'at:', ctime()
self.res = apply(self.func, self.args)
print self.name, 'finished at:', ctime()
def writeQueue(queue):
queue.put('Anything', 1)
print "Producing object for Queue. Size now", queue.qsize()
def readQueue(queue):
val = queue.get(1)
print 'Consumed object from Queue. Size now', queue.qsize()
def produce(queue, loops):
for i in range(loops):
writeQueue(queue)
sleep(randint(1,3))
def consume(queue, loops):
for i in range(loops):
readQueue(queue)
sleep(randint(2,5))
def main():
funcs = [produce, consume]
nfuncs = range(len(funcs))
nloops = randint(2, 5)
queue = Queue(32)
threads = []
for i in nfuncs:
t = MyThread(funcs[i], (queue, nloops),funcs[i].__name__)
threads.append(t)
for i in nfuncs:
threads[i].start()
for i in nfuncs:
threads[i].join()
print 'All Done!!'
if __name__ == '__main__':
main()
|