pathos_worker_objects.py

import multiprocessing as mp

from pathos.multiprocessing import ProcessingPool as Pool


# Create pool
p = Pool(processes=1, ncpus=3)


print(dir(p))
print(p)


quit()
# Execute
# TODO: calculate the chunksize value based on: total starcount and cores used.
r = list(p.imap_unordered(self.evolve_system_mp, self.yield_system_mp(), chunksize=20))