Initial multi-threaded source-pipe-sink support. WIP
More pipe WIP