File Coverage

blib/lib/Time/StopWatchWithMessage.pm

Criterion	Covered	Total	%
statement	16	75	21.3
branch	0	12	0.0
condition	0	8	0.0
subroutine	6	15	40.0
pod	6	7	85.7
total	28	117	23.9

package Time::StopWatchWithMessage;
use strict;
use warnings;
use List::Util qw( sum max reduce );
use List::MoreUtils qw( first_index );
use Time::HiRes qw( gettimeofday tv_interval );

our $VERSION     = "0.06";
our $IS_REALTIME = 0;
our $LENGTH      = 3;

sub new { bless [ ], shift }

sub start {
    my $self    = shift;
    my $message = shift || __PACKAGE__ . ">>> Start watching.";

    $self->stop
        if $self->_does_stop_need;

    push @{ $self }, { time => [ gettimeofday ], message => $message };

    return $self;
}

sub stop {
    my $self = shift;
    my $time = [ gettimeofday ];

    my $previous = pop @{ $self };
    $previous->{time} = tv_interval( $previous->{time}, $time );

    push @{ $self }, $previous;

    if ( $IS_REALTIME ) {
        warn sprintf "%s - %.${LENGTH}f[s]\n", $previous->{message}, $previous->{time};
    }

    return $self;
}

sub _does_stop_need {
    my $self = shift;
    return @{ $self } && ref $self->[-1]{time} eq ref [ ];
}

sub collapse {
    my $self = shift;

    $self->stop
        if $self->_does_stop_need;

    my $watches_ref = reduce {
        my $i = first_index { $_->{message} eq $b->{message} } @{ $a };

        if ( $i >= 0 ) {
            $a->[ $i ]{time} += $b->{time};
            $a->[ $i ]{count}++;
        }
        else {
            push @{ $a }, $b;
        }

        $a;
    } ( [ ], @{ $self } );

    return bless $watches_ref, ref $self;
}

sub _output {
    my $self = shift;
    my $FH   = shift;

    $self->stop
        if $self->_does_stop_need;

    my $sum    = sum( map { $_->{time} } @{ $self } );
    my $max    = max( map { $_->{time} } @{ $self } );
    my %length = (
        time    => max( map { length int $_->{time} } @{ $self } ),
        message => max( map { length $_->{message} }  @{ $self } ),
    );

    OUTPUT_ALL_WATCHES:
    while ( defined( my $watch_ref = shift @{ $self } ) ) {
        my $output = sprintf(
            "%$length{message}s - %$length{time}.${LENGTH}f[s] / %$length{time}.${LENGTH}f[s] = %$length{time}.${LENGTH}f[%%]",
            $watch_ref->{message},
            $watch_ref->{time},
            $sum,
            $watch_ref->{time} / $sum * 100,
        );

        if ( $watch_ref->{count} ) {
            $output = join q{; }, $output, sprintf "%d times measured.", $watch_ref->{count} + 1;
        }

        print { $FH } $output, "\n";
    }

    return;
}

sub output {
    my $self = shift;
    my $FH   = shift || *STDERR;

    return $self->_output( $FH );
}

sub print { shift->_output( *STDOUT ) }

sub warn { shift->_output( *STDERR ) }

1;

__END__