streaming: add simple multithreading