Improved concurrent mpsc queue's API