Split up the `create_distributed_threads` to create the queue and threads separately. Others to follow.
Split up the
create_distributed_threadsto create the queue and threads separately.Others to follow.