File Coverage

blib/lib/Pipeline/Segment/Async/IThreads.pm

Criterion	Covered	Total	%
statement	22	39	56.4
branch	1	4	25.0
condition			n/a
subroutine	8	12	66.6
pod	4	5	80.0
total	35	60	58.3

package Pipeline::Segment::Async::IThreads;

use strict;
use warnings;
our $VERSION = "3.12";

BEGIN {
  use Config;
  if ($Config{useithreads}) {
    $Pipeline::Segment::Async::IThreads::AVAILABLE = 1;
    require threads;
    threads->import;
  } else {
    $Pipeline::Segment::Async::IThreads::AVAILABLE = 0;
  }
}

use Config;
use Pipeline::Segment::Async::Handler;
use base qw( Pipeline::Segment::Async::Handler );

sub canop {
  my $self = shift;
  $Pipeline::Segment::Async::IThreads::AVAILABLE
}

sub run {
  my $self = shift;
  my $sub  = shift;
  my @args = @_;
  $self->thread( threads->create( $sub, @args ) );
}

sub thread {
  my $self   = shift;
  my $thread = shift;
  if (defined( $thread )) {
    $self->{ thread } = $thread;
    return $self;
  } else {
    return $self->{ thread };
  }
}

sub reattach {
  my $self = shift;
  return $self->thread->join();
}

sub discard {
  my $self = shift;
  $self->thread->detach();
}

1;

__END__