gistfile1.txt

use Coro;
use Coro::Channel;
use Coro::Timer;
use Plack::Request;

my $queue = Coro::Channel->new(100);
for ( 1..10 ) {
    async {
        while(1) {
            my $req = $queue->get();
            my ($path_info, $guard) = @{$req};
            Coro::Timer::sleep 3;
            warn "finish". $path_info;
            $guard->end;
        }
    };
}


sub {
    my $env = shift;
    my $req = Plack::Request->new($env);

    warn "start". $path_info;
    $env->{'psgix.exit_guard'}->begin;
    $queue->put([$req->path_info,$env->{'psgix.exit_guard'}]);

    [200,['Content-Type'=>'text/plain'],["OK ". $req->path_info ."\n"]];
};