async {
    while( $Q->dequeue() ) {
        ## process message.
    }
};

async {
    until( $dieNow  ) {
        sleep $someTime;
        ## do housekeeping.
    }
};