NAME

Mojo::IOLoop::ReadWriteProcess::Queue - Queue for Mojo::IOLoop::ReadWriteProcess objects.

SYNOPSIS

            

              
              
use Mojo::IOLoop::ReadWriteProcess qw(queue process);
my $n_proc = 20;
my $fired;
my $q = queue;
$q->pool->maximum_processes(2); # Max 2 processes in parallel
$q->queue->maximum_processes(10); # Max queue is 10
$q->add( process sub { return 42 } ) for 1..7;
# Subscribe to all "stop" events in the pool
$q->once(stop => sub { $fired++; });
# Consume the queue
$q->consume();
my $all = $q->done; # All processes, Mojo::Collection of Mojo::IOLoop::ReadWriteProcess
# Set your own running pool
$q->pool(parallel sub { return 42 } => 5);
# Set your own queue
$q->queue(parallel sub { return 42 } => 20);
$q->consume();
            
          

METHODS

Mojo::IOLoop::ReadWriteProcess::Queue inherits all methods from Mojo::Base and implements the following new ones. Note: It proxies all the other methods of Mojo::IOLoop::ReadWriteProcess for the whole process group.

add

            

              
              
use Mojo::IOLoop::ReadWriteProcess qw(queue process);
my $q = queue();
$q->add(sub { print "Hello 2! " });
$q->add(process sub { print "Hello 2! " });
            
          

Add the process to the queue.

consume

            

              
              
use Mojo::IOLoop::ReadWriteProcess qw(queue);
my $q = queue();
$q->add(sub { print "Hello 2! " });
$q->add(process sub { print "Hello 2! " });
$q->consume; # executes and exhaust the processes
            
          

Starts the processes and empties the queue. Note: maximum_processes can be set both to the pool (number of process to be run in parallel), and for the queue (that gets exhausted during the consume() phase).

            

              
              
$q->pool->maximum_processes(2); # Max 2 processes in parallel
$q->queue->maximum_processes(10); # Max queue is 10
            
          

exhausted

            

              
              
use Mojo::IOLoop::ReadWriteProcess qw(queue);
my $q = queue();
$q->add(sub { print "Hello 2! " });
$q->add(process sub { print "Hello 2! " });
$q->consume; # executes and exhaust the processes
$q->exhausted; # 1
            
          

Returns 1 if the queue is exhausted.

ENVIRONMENT

You can set the MOJO_PROCESS_MAXIMUM_PROCESSES environment variable to specify the the maximum number of processes allowed in the pool and the queue, that are Mojo::IOLoop::ReadWriteProcess::Pool instances.

            

              
              
MOJO_PROCESS_MAXIMUM_PROCESSES=10000
            
          

LICENSE

Copyright (C) Ettore Di Giacinto.

This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself.

AUTHOR

Ettore Di Giacinto <edigiacinto@suse.com>