safe emit queue: use blocking queue between Thrift and Lwt