Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from multiprocessing import Pool
- import time
- import numpy
- def takeuptime(ntrials):
- for ii in xrange(ntrials):
- junk = numpy.std(numpy.random.randn(1e5))
- return junk
- if __name__ == "__main__":
- start = time.time()
- map(takeuptime, [500, 500])
- print "Serial time: %f" % (time.time() - start)
- start = time.time()
- pool = Pool(processes=2)
- pool.map(takeuptime, [500, 500])
- print "Parallel time: %f" % (time.time() - start)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement