Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import multiprocessing as mp
- import time
- def f(x):
- return x*x
- def main():
- pool = mp.Pool()
- results = pool.imap_unordered(f, range(1, 6))
- time.sleep(1)
- print str(results.next())
- pool.close()
- pool.join()
- if __name__ == '__main__':
- main()
- import multiprocessing as mp
- import time
- def f(args):
- x = args[0]
- q = args[1]
- q.put(str(x))
- time.sleep(0.1)
- return x*x
- def main():
- q = mp.Queue()
- pool = mp.Pool()
- results = pool.imap_unordered(f, ([i, q] for i in range(1, 6)))
- print str(q.get())
- pool.close()
- pool.join()
- if __name__ == '__main__':
- main()
- import multiprocessing as mp
- import time
- q = mp.Queue()
- def f(x):
- q.put(str(x))
- return x*x
- def main():
- pool = mp.Pool()
- results = pool.imap_unordered(f, range(1, 6))
- time.sleep(1)
- print q.get()
- pool.close()
- pool.join()
- if __name__ == '__main__':
- main()
- import multiprocessing as mp
- def f(x):
- f.q.put('Doing: ' + str(x))
- return x*x
- def f_init(q):
- f.q = q
- def main():
- jobs = range(1,6)
- q = mp.Queue()
- p = mp.Pool(None, f_init, [q])
- results = p.imap(f, jobs)
- p.close()
- for i in range(len(jobs)):
- print q.get()
- print results.next()
- if __name__ == '__main__':
- main()
- import multiprocessing as mp
- from random import *
- def f(x):
- myId=random()
- output=[]
- while not f.q.empty():
- z=f.q.get()
- print (str(myId)+"#"+str(z))
- output.append(z)
- print(str(myId)+" ok")
- return output
- def f_init(q):
- f.q = q
- def main():
- jobs = []
- q = mp.Queue()
- for x in range(10):
- q.put([x,2*x,3*x])
- jobs.append(x)
- p = mp.Pool(None, f_init, [q])
- results = p.imap(f, jobs)
- p.close()
- for bResult in results:
- print(bResult)
- if __name__ == '__main__':
- main()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement