threads::shared 1.22

[p5sagit/p5-mst-13.2.git] / ext / threads / shared / t / cond.t

diff --git a/ext/threads/shared/t/cond.t b/ext/threads/shared/t/cond.t
index 71ac219..3a6bfdf 100644 (file)
--- a/ext/threads/shared/t/cond.t
+++ b/ext/threads/shared/t/cond.t
@@ -8,7 +8,7 @@ BEGIN {
     }
     use Config;
     if (! $Config{'useithreads'}) {
-        print("1..0 # Skip: Perl not compiled with 'useithreads'\n");
+        print("1..0 # SKIP Perl not compiled with 'useithreads'\n");
         exit(0);
     }
 }
@@ -33,7 +33,7 @@ sub ok {
 
 BEGIN {
     $| = 1;
-    print("1..82\n");   ### Number of tests that will be run ###
+    print("1..32\n");   ### Number of tests that will be run ###
 };
 
 use threads;
@@ -212,7 +212,7 @@ $Base++;
             lock($counter);
             if ($n > 0) {
                 $counter++;
-                $th = threads->new(\&broad, $n-1);
+                $th = threads->create(\&broad, $n-1);
                 cond_wait($counter);
                 $counter += 10;
             }
@@ -224,7 +224,7 @@ $Base++;
         $th->join if $th;
     }
 
-    threads->new(\&broad, 3)->join;
+    threads->create(\&broad, 3)->join;
     ok(2, $counter == 33, "cond_broadcast: all three threads woken");
 
     $Base += 2;
@@ -243,7 +243,7 @@ $Base++;
             lock($r);
             if ($n > 0) {
                 $$r++;
-                $th = threads->new(\&broad2, $n-1);
+                $th = threads->create(\&broad2, $n-1);
                 cond_wait($r);
                 $$r += 10;
             }
@@ -255,7 +255,7 @@ $Base++;
         $th->join if $th;
     }
 
-    threads->new(\&broad2, 3)->join;;
+    threads->create(\&broad2, 3)->join;;
     ok(2, $$r == 33, "cond_broadcast: ref: all three threads woken");
 
     $Base += 2;
@@ -282,39 +282,6 @@ $Base++;
     $Base += 4;
 }
 
-
-# Stress test
-{
-    my $cnt = 50;
-
-    my $mutex = 1;
-    share($mutex);
-
-    my @threads;
-    for (1..$cnt) {
-        my $thread = threads->create(sub {
-                        my $arg = $_;
-                        my $result = 0;
-                        for (0..1000000) {
-                            $result++;
-                        }
-                        lock($mutex);
-                        while ($mutex != $_) {
-                            cond_wait($mutex);
-                        }
-                        $mutex++;
-                        cond_broadcast($mutex);
-                        return $result;
-                      });
-        push(@threads, $thread);
-    }
-
-    for (1..$cnt) {
-        my $result = $threads[$_-1]->join();
-        ok($_, defined($result) && ("$result" eq '1000001'), "stress test - iter $_");
-    }
-
-    $Base += $cnt;
-}
+exit(0);
 
 # EOF