use strict;
use warnings;
use feature 'say';

use IO::Async::Loop;
use IO::Async::Timer::Periodic;

use lib '.';
use Runner;

use constant {
    WORKERS   => 5,
    INTERVAL  => 2,
    MAX_BATCH => 32,     # MIN is 1
};
my $event_id = 0;
my ( $runner, $timer );

my $loop   = IO::Async::Loop-> new;
$runner    = Runner-> new( $loop, WORKERS );
$timer     = IO::Async::Timer::Periodic-> new(
    interval => INTERVAL,
    on_tick  => sub {
        printf ">>>>> time: %d, workers busy: %d, batches: %d\n",
            time - $^T,
            scalar $loop-> notifiers - 1,       # exclude timer,
            scalar $timer-> adopted_futures; 
        
        my $batch = int rand MAX_BATCH;
        
        $timer-> adopt_future( 
            $runner-> call([ $event_id .. $event_id + $batch ])
                   -> on_ready( sub {
                       my $f = shift;
                       my @id_list = $f-> get;
                       say 'batch done: ', join ',', @id_list
                   })
        );
        $event_id += $batch + 1
    },
);
$timer-> start;
$loop-> add( $timer );
$loop-> run;