Refactor msgq thread classes to use gru.msgq_runner