Improve code structure and logging
Test writing to blocking sinks
Automatically determine number of cores
Add parallel word count example