BEGIN {                         # Magic Perl CORE pragma
    if ($ENV{PERL_CORE}) {
        chdir 't' if -d 't';
        @INC = '../lib';
    }
}
use Test::More tests => 26;
use strict;
use warnings;
use_ok( 'Thread::Synchronized' );
can_ok( 'Thread::Synchronized',qw(
 import
) );
my $script = 'test1';
ok( open( my $handle,'>',$script ),  'create test script' );
ok( (print $handle <<'EOD'),              'write test script' );
use threads;
use threads::shared;
use Thread::Synchronized;
sub a : synchronized {
    my $tid = threads->tid;
    foreach (1..3) {
        print "$tid: $_\n";
        sleep 1;
    }
} #a
$| = 1;
my @thread;
push( @thread,threads->new( \&a ) ) foreach 1..3;
$_->join foreach @thread;
EOD
ok( close( $handle ),                   'close test script' );
ok( open( $handle,"$^X -Ilib $script|" ),'run test script and fetch output');
my %seen = ();
my $tests = 0;
while (<$handle>) {
    last unless m#^(\d+):#; $tests++;
    my $seen = $1;
    last if $seen{$seen}; $tests++;
    $seen{$seen} = $seen;
    foreach my $times (1..2) {
        last unless <$handle> =~ m#^$seen:#; $tests++;
    }
}
is( "@{[sort keys %seen]}",'1 2 3','check if all threads returned' );
is( $tests,'12','check if all lines returned' );
close $handle;
ok( open( $handle,'>',$script ),     'create 2nd test script' );
ok( (print $handle <<'EOD'),              'write 2nd test script' );
use threads;
use threads::shared;
use Thread::Synchronized;
sub a : synchronized { 1 }
sub foo::a : synchronized { 1 }
package bar;
sub a : synchronized { 1 }
print "@{[sort keys %Thread::Synchronized::VERSION]}";
EOD
ok( close( $handle ),                   'close 2nd test script' );
ok( open( $handle,"$^X -Ilib $script|" ),'run 2nd test script, fetch output');
is( (scalar <$handle>),'bar::a foo::a main::a','check if subs were found' );
close $handle;
ok( open( $handle,'>',$script ),     'create 3rd test script' );
ok( (print $handle <<'EOD'),              'write 3rd test script' );
use threads;
use threads::shared;
use Thread::Synchronized;
my $object : shared;
sub a : synchronized method {
    my $tid = threads->tid;
    foreach (1..3) {
        print "$tid: $_\n";
        sleep 1;
    }
} #a
$| = 1;
my @thread;
push( @thread,threads->new( \&a,$object ) ) foreach 1..3;
$_->join foreach @thread;
EOD
ok( close( $handle ),                   'close 3rd test script' );
ok( open( $handle,"$^X -Ilib $script|" ),'run 3rd test script and fetch output');
%seen = ();
$tests = 0;
while (<$handle>) {
    last unless m#^(\d+):#; $tests++;
    my $seen = $1;
    last if $seen{$seen}; $tests++;
    $seen{$seen} = $seen;
    foreach my $times (1..2) {
        last unless <$handle> =~ m#^$seen:#; $tests++;
    }
}
is( "@{[sort keys %seen]}",'1 2 3','check if all threads returned' );
is( $tests,'12','check if all lines returned' );
close $handle;
SKIP: {
    skip( "load.pm not ready for ondemand source filters yet",6 ) if 1;
    eval {require load};
    skip( "load.pm not found",6 ) unless defined $load::VERSION;
    skip( "load.pm not recent enough",6 ) if $load::VERSION < 0.12;
    ok( open( $handle,'>',$script ), 'create 4th test script' );
    ok( (print $handle <<'EOD'),          'write 4th test script' );
package Foo;
BEGIN {$INC{'Foo'} = 'test1'} # so that load.pm can find the source
use threads;
use threads::shared;
use load;
use Thread::Synchronized;
a();
$| = 1;
my @thread;
push( @thread,threads->new( \&a ) ) foreach 1..3;
$_->join foreach @thread;
__END__
sub a : synchronized {
    my $tid = threads->tid;
    foreach (1..3) {
        print "$tid: $_\n";
        sleep 1;
    }
} #a
EOD
    ok( close( $handle ),                       'close 4th test script' );
    ok( open( $handle,"$^X -Ilib -I. $script|" ),'run 4th test script and fetch output');
    %seen = ();
    $tests = 0;
    while (<$handle>) {
        last unless m#^(\d+):#; $tests++;
        my $seen = $1;
        last if $seen{$seen}; $tests++;
        $seen{$seen} = $seen;
        foreach my $times (1..2) {
            last unless <$handle> =~ m#^$seen:#; $tests++;
        }
    }
    is( "@{[sort keys %seen]}",'1 2 3','check if all threads returned' );
    is( $tests,'12','check if all lines returned' );
    close $handle;
}
ok( unlink( $script ),                  'remove test files' );