I want to run a cpu intensive program in Python across multiple cores and am trying to figure out how to write C extensions to do this. Are there any code samples or tutorials on this?
You can already break a Python program into multiple processes. The OS will already allocate your processes across all the cores.
Do this.
python part1.py | python part2.py | python part3.py | ... etc.
The OS will assure that part uses as many resources as possible. You can trivially pass information along this pipeline by using cPickle
on sys.stdin
and sys.stdout
.
Without too much work, this can often lead to dramatic speedups.
Yes -- to the haterz -- it's possible to construct an algorithm so tortured that it may not be sped up much. However, this often yields huge benefits for minimal work.
And.
The restructuring for this purpose will exactly match the restructuring required to maximize thread concurrency. So. Start with shared-nothing process parallelism until you can prove that sharing more data would help, then move to the more complex shared-everything thread parallelism.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With