Threaded Streaming Executor

[dmatveev]

The current implementation is a threading overkill - was relatively easy to implement, but brings enormous overhead with a high number of threads and queues used. A better version can be designed based on principles of #13.