The second example provides a method for passing messages to the threads. You could make the messages 2-part: the first part for selecting which thread should process it, and the second part the action/message.

Receiving threads which are not the intended recpipent would re-queue it. This is slightly inefficient, but, depending on the number or syncs required, this could be a reasonable mechanism.