xyzshop/rdispatcher/coprocessor.php

<?php


class coprocessor extends processor
{
    public function __construct()
    {
        parent::__construct(true);
    }

    protected function handle($msg)
    {
        go(function() use ($msg) {
            parent::handle($msg);
        });
    }
}