gistfile1.pl

use common::sense;
use EV;
use AnyEvent;
use AnyEvent::Util;
use AnyEvent::CouchDB;

my @_queue = ();
my $_IS_RUNNING = 0;
    
sub _schedule;
sub _schedule {
    while () {
        if (! $_IS_RUNNING and my $cb = shift @_queue) {
            $_IS_RUNNING = 1;
            $cb->(AnyEvent::Util::guard { $_IS_RUNNING = 0; _schedule; });
        } else {
            last;
        }
    }
}

sub _wait {
    push @_queue, $_[0];
    _schedule if ! $_IS_RUNNING;
}

my $get_all_dbs = sub {
    _wait sub {
        my $couch = couch('http://localhost:5984/');
        my $data = $couch->all_dbs->recv;
    };
};

my @handles = map { AE::timer 0, 100.25, $get_all_dbs } (0 .. 100);

EV::loop;