A C++ implementation of a concurrent message queue