X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=ext%2Fthreads%2Ft%2Fthread.t;h=63ad1ac95d48b98a33acf41c3a3237d95e002a48;hb=fc04eb160a90a82da7112a76ae84e7fb117eae45;hp=befc4a445cfa2053fff74fc07b56532690c46ac4;hpb=0f1612a7416fa2b6a078554fb1e7168e5fd5c31c;p=p5sagit%2Fp5-mst-13.2.git

diff --git a/ext/threads/t/thread.t b/ext/threads/t/thread.t
index befc4a4..63ad1ac 100644
--- a/ext/threads/t/thread.t
+++ b/ext/threads/t/thread.t
@@ -7,9 +7,9 @@ BEGIN {
         unshift @INC, '../lib';
     }
     use Config;
-    unless ($Config{'useithreads'}) {
-        print "1..0 # Skip: no useithreads\n";
-        exit 0;
+    if (! $Config{'useithreads'}) {
+        print("1..0 # Skip: Perl not compiled with 'useithreads'\n");
+        exit(0);
     }
 
     require($ENV{PERL_CORE} ? "./test.pl" : "./t/test.pl");
@@ -17,27 +17,32 @@ BEGIN {
 
 use ExtUtils::testlib;
 
-BEGIN { $| = 1; print "1..31\n" };
+BEGIN {
+    $| = 1;
+    print("1..31\n");   ### Number of tests that will be run ###
+};
+
 use threads;
 use threads::shared;
+print("ok 1 - Loaded\n");
 
-print "ok 1\n";
+### Start of Testing ###
 
 sub content {
     print shift;
     return shift;
 }
 {
-    my $t = threads->new(\&content, "ok 2\n", "ok 3\n", 1..1000);
+    my $t = threads->create(\&content, "ok 2\n", "ok 3\n", 1..1000);
     print $t->join();
 }
 {
     my $lock : shared;
     my $t;
     {
-	lock($lock);
-	$t = threads->new(sub { lock($lock); print "ok 5\n"});
-	print "ok 4\n";
+        lock($lock);
+        $t = threads->create(sub { lock($lock); print "ok 5\n"});
+        print "ok 4\n";
     }
     $t->join();
 }
@@ -47,18 +52,18 @@ sub dorecurse {
     my $ret;
     print $val;
     if(@_) {
-	$ret = threads->new(\&dorecurse, @_);
-	$ret->join;
+        $ret = threads->create(\&dorecurse, @_);
+        $ret->join;
     }
 }
 {
-    my $t = threads->new(\&dorecurse, map { "ok $_\n" } 6..10);
+    my $t = threads->create(\&dorecurse, map { "ok $_\n" } 6..10);
     $t->join();
 }
 
 {
     # test that sleep lets other thread run
-    my $t = threads->new(\&dorecurse, "ok 11\n");
+    my $t = threads->create(\&dorecurse, "ok 11\n");
     threads->yield; # help out non-preemptive thread implementations
     sleep 1;
     print "ok 12\n";
@@ -67,16 +72,16 @@ sub dorecurse {
 {
     my $lock : shared;
     sub islocked {
-	lock($lock);
-	my $val = shift;
-	my $ret;
-	print $val;
-	if (@_) {
-	    $ret = threads->new(\&islocked, shift);
-	}
-	return $ret;
+        lock($lock);
+        my $val = shift;
+        my $ret;
+        print $val;
+        if (@_) {
+            $ret = threads->create(\&islocked, shift);
+        }
+        return $ret;
     }
-my $t = threads->new(\&islocked, "ok 13\n", "ok 14\n");
+my $t = threads->create(\&islocked, "ok 13\n", "ok 14\n");
 $t->join->join;
 }
 
@@ -103,8 +108,8 @@ sub threaded {
 { 
     curr_test(15);
 
-    my $thr1 = threads->new(\&testsprintf, 15);
-    my $thr2 = threads->new(\&testsprintf, 16);
+    my $thr1 = threads->create(\&testsprintf, 15);
+    my $thr2 = threads->create(\&testsprintf, 16);
     
     my $short = "This is a long string that goes on and on.";
     my $shorte = " a long string that goes on and on.";
@@ -147,10 +152,10 @@ package main;
 }
 {
     # there is a little chance this test case will falsly fail
-    # since it tests rand	
+    # since it tests rand       
     my %rand : shared;
     rand(10);
-    threads->new( sub { $rand{int(rand(10000000000))}++ } ) foreach 1..25;
+    threads->create( sub { $rand{int(rand(10000000000))}++ } ) foreach 1..25;
     $_->join foreach threads->list;
 #    use Data::Dumper qw(Dumper);
 #    print Dumper(\%rand);
@@ -161,7 +166,7 @@ package main;
 # bugid #24165
 
 run_perl(prog =>
-    'use threads; sub a{threads->new(shift)} $t = a sub{}; $t->tid; $t->join; $t->tid');
+    'use threads; sub a{threads->create(shift)} $t = a sub{}; $t->tid; $t->join; $t->tid');
 is($?, 0, 'coredump in global destruction');
 
 # test CLONE_SKIP() functionality
@@ -222,56 +227,56 @@ if ($] >= 5.008007) {
     package main;
 
     {
-	my @objs;
-	for my $class (qw(A A1 A2 B B1 B2 C C1 C2 D D1)) {
-	    push @objs, bless [], $class;
-	}
-
-	sub f {
-	    my $depth = shift;
-	    my $cloned = ""; # XXX due to recursion, doesn't get initialized
-	    $cloned .= "$_" =~ /ARRAY/ ? '1' : '0' for @objs;
-	    is($cloned, ($depth ? '00010001111' : '11111111111'),
-		"objs clone skip at depth $depth");
-	    threads->new( \&f, $depth+1)->join if $depth < 2;
-	    @objs = ();
-	}
-	f(0);
+        my @objs;
+        for my $class (qw(A A1 A2 B B1 B2 C C1 C2 D D1)) {
+            push @objs, bless [], $class;
+        }
+
+        sub f {
+            my $depth = shift;
+            my $cloned = ""; # XXX due to recursion, doesn't get initialized
+            $cloned .= "$_" =~ /ARRAY/ ? '1' : '0' for @objs;
+            is($cloned, ($depth ? '00010001111' : '11111111111'),
+                "objs clone skip at depth $depth");
+            threads->create( \&f, $depth+1)->join if $depth < 2;
+            @objs = ();
+        }
+        f(0);
     }
 
     curr_test(curr_test()+2);
     ok(eq_hash(\%c,
-	{
-	    qw(
-		A-A	2
-		A1-A1	2
-		A1-A2	2
-		B-B	2
-		B1-B1	2
-		B1-B2	2
-		C-C	2
-		C1-C1	2
-		C1-C2	2
-	    )
-	}),
-	"counts of calls to CLONE_SKIP");
+        {
+            qw(
+                A-A     2
+                A1-A1   2
+                A1-A2   2
+                B-B     2
+                B1-B1   2
+                B1-B2   2
+                C-C     2
+                C1-C1   2
+                C1-C2   2
+            )
+        }),
+        "counts of calls to CLONE_SKIP");
     ok(eq_hash(\%d,
-	{
-	    qw(
-		A-A	1
-		A1-A1	1
-		A1-A2	1
-		B-B	3
-		B1-B1	1
-		B1-B2	1
-		C-C	1
-		C1-C1	3
-		C1-C2	3
-		D-D	3
-		D-D1	3
-	    )
-	}),
-	"counts of calls to DESTROY");
+        {
+            qw(
+                A-A     1
+                A1-A1   1
+                A1-A2   1
+                B-B     3
+                B1-B1   1
+                B1-B2   1
+                C-C     1
+                C1-C1   3
+                C1-C2   3
+                D-D     3
+                D-D1    3
+            )
+        }),
+        "counts of calls to DESTROY");
 
 } else {
     print("ok 27 # Skip objs clone skip at depth 0\n");