Parallel::Benchmark + RedisDB

pb_redis_ver2.pl

use strict;
use warnings;
use Data::Dumper;
use Parallel::Benchmark;
use RedisDB;

use String::Random;

my $host = shift || 'localhost';
my $port = shift || '6379';
my @ports = split /,/, $port;

my $time = 30;

my $bm = Parallel::Benchmark->new(
    setup => sub {
        my $self = shift;
        my $seq = 0;
        for my $port (@ports) {
             $self->stash->{redis}->[$seq] = RedisDB->new(host => $host, port => $port);
             $seq++;
        }
    },
    benchmark => sub {
        my ($self, $id) = @_;
        my $rand = int(rand(scalar @{$self->stash->{redis}}));
        my $redis = $self->stash->{redis}->[$rand];
        my $key   = String::Random->new->randregex('[A-Za-z0-9]{12}');
        my $value = String::Random->new->randregex('[A-Za-z0-9]{64}');
        my $status = $redis->set($key, $value);
        #my $status = $redis->lpush('list_key', '{"hyoro":"1234567890"}');
        #$self->stash->{result}->{ success }++;
        1;
    },
    teardown => sub {
        my $self = shift;
        delete $self->stash->{redis};
    },
    time => $time,
);
for my $c ( 16, 32, 48, 54 ) {
    $bm->concurrency($c);
    my $result = $bm->run();
    #print Dumper $result;
}