Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from zlib import compress, decompress
- from time import time
- import threading
- import random
- import string
- #DAT = ''.join(random.choice(string.letters) for _ in xrange(8*1024))
- DAT = 'hello'
- #DAT = compress(DAT)
- #print "compressed size:", len(DAT)
- flag = threading.Event()
- def worker():
- D=DAT
- #dec = decompress
- dec = compress
- flag.wait()
- for i in xrange(10000):
- dec(D)
- flag.set()
- t = time()
- worker()
- t = time()-t
- print "Single thread:", t*1000, "[ms]"
- flag.clear()
- t1=threading.Thread(target=worker)
- t2=threading.Thread(target=worker)
- t1.start()
- t2.start()
- t = time()
- flag.set()
- t1.join()
- t2.join()
- t = time()-t
- print "Double thread:", t*1000, "[ms]"
Add Comment
Please, Sign In to add comment