Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import multiprocessing
- import time
- data = (
- {"var":1, "shared": None}, {"var":2, "shared": None}, {"var":3, "shared": None}, {"var":4, "shared": None}
- )
- def mp_worker(input):
- print input
- # print " Processs %stWaiting %s seconds" % (inputs, the_time)
- # time.sleep(int(the_time))
- # print " Process %stDONE" % inputs
- def mp_handler():
- p = multiprocessing.Pool(2)
- p.map(mp_worker, data)
- if __name__ == '__main__':
- mp_handler()
Add Comment
Please, Sign In to add comment