Parallel pings using threads

ping_parallel_threads.pl

#!/usr/bin/perl

use strict;
use warnings;
use threads;
use threads::shared;
use Thread::Queue;
use JSON::XS;
use Net::Ping;
use Data::Dumper;

my @data = qw(
	8.8.8.8
	8.8.4.4
	google.com
);

my @result = parallel3(
	2,
	sub {
		my $ping = new Net::Ping('icmp');
		$ping->hires();
		return [ $ping->ping(shift,0.5) ];
	},
	@data
);

print Dumper \@result;


exit;

sub parallel3 {
   my ( $max, $handler, @args ) = @_;

    my $json = JSON::XS->new;
    my $q = Thread::Queue->new;

    return () if @args == 0;
    if ( $max > @args ) { $max = @args }

    $q->limit = $max;
    my @out : shared;

    for ( 1..$max ) {
        threads->create(sub {
            while ( defined(my $d = $q->dequeue()) ) {
                my ($result) = $handler->($d->[1]);
                $out[$d->[0]] = $json->allow_nonref->encode($result);
            }
        });
    }

    my $idx = 0;
    foreach ( @args ) {
        $q->enqueue([$idx++,$_]);
    }
    $q->end;

    foreach ( threads->list ) {
        $_->join;
    }

return map { $json->allow_nonref->decode($_) } @out;