import multiprocessing
from math import *
def chunks(l, n):
return [l[i:i+n] for i in range(0, len(l), n)]
def f(x):
print(x)
result = 0
for i in x:
print(i)
result +=i
return result
def handler(data, job_number):
p = multiprocessing.Pool(job_number)
total = len(data)
chunk_size
= ceil(total
/ job_number
) slice = chunks(data, chunk_size)
r=p.map(f, slice)
return r
if __name__ == '__main__':
data = range(0,11)
result = handler(data, 2)
print(result)
aW1wb3J0IG11bHRpcHJvY2Vzc2luZwpmcm9tIG1hdGggaW1wb3J0ICoKZGVmIGNodW5rcyhsLCBuKToKICAgIHJldHVybiBbbFtpOmkrbl0gZm9yIGkgaW4gcmFuZ2UoMCwgbGVuKGwpLCBuKV0KCmRlZiBmKHgpOgogICAgcHJpbnQoeCkKICAgIHJlc3VsdCA9IDAKICAgIGZvciBpIGluIHg6CiAgICAgICAgcHJpbnQoaSkKICAgICAgICByZXN1bHQgKz1pCiAgICByZXR1cm4gcmVzdWx0CgpkZWYgaGFuZGxlcihkYXRhLCBqb2JfbnVtYmVyKToKICAgIHAgPSBtdWx0aXByb2Nlc3NpbmcuUG9vbChqb2JfbnVtYmVyKQogICAgdG90YWwgPSBsZW4oZGF0YSkKICAgIGNodW5rX3NpemUgPSBjZWlsKHRvdGFsIC8gam9iX251bWJlcikKICAgIHNsaWNlID0gY2h1bmtzKGRhdGEsIGNodW5rX3NpemUpCiAgICByPXAubWFwKGYsIHNsaWNlKQogICAgcmV0dXJuIHIKCmlmIF9fbmFtZV9fID09ICdfX21haW5fXyc6CiAgICBkYXRhID0gcmFuZ2UoMCwxMSkKICAgIHJlc3VsdCA9IGhhbmRsZXIoZGF0YSwgMikKICAgIHByaW50KHJlc3VsdCk=