Change parallel actor graph to be purely push-based. (#70)
In consumer::begin, wait for all threads to initialize.
Remove state_base::done and introduce new worker state DONE.
Handle pushing in end() in parallel.