Thread::Queue 2.11

From: "Jerry D. Hedden" <jdhedden@cpan.org>
Message-ID: <1ff86f510806120642g5a707382l76aaaa80797443c8@mail.gmail.com>

This time, not empty.

p4raw-id: //depot/perl@34051

9 files changed, 25 insertions, 9 deletions

diff --git a/lib/Thread/Queue.pm b/lib/Thread/Queue.pm
index 686d62f33e..631edf126a 100644
--- a/lib/Thread/Queue.pm
+++ b/lib/Thread/Queue.pm
@@ -3,7 +3,7 @@ package Thread::Queue;
 use strict;
 use warnings;
 
-our $VERSION = '2.09';
+our $VERSION = '2.11';
 
 use threads::shared 1.21;
 use Scalar::Util 1.10 qw(looks_like_number blessed reftype refaddr);
@@ -209,7 +209,7 @@ Thread::Queue - Thread-safe queues
 
 =head1 VERSION
 
-This document describes Thread::Queue version 2.09
+This document describes Thread::Queue version 2.11
 
 =head1 SYNOPSIS
 
@@ -462,7 +462,7 @@ Thread::Queue Discussion Forum on CPAN:
 L<http://www.cpanforum.com/dist/Thread-Queue>
 
 Annotated POD for Thread::Queue:
-L<http://annocpan.org/~JDHEDDEN/Thread-Queue-2.09/lib/Thread/Queue.pm>
+L<http://annocpan.org/~JDHEDDEN/Thread-Queue-2.11/lib/Thread/Queue.pm>
 
 Source repository:
 L<http://code.google.com/p/thread-queue/>
diff --git a/lib/Thread/Queue/t/01_basic.t b/lib/Thread/Queue/t/01_basic.t
index 0a77e3e217..6a0d8387e8 100644
--- a/lib/Thread/Queue/t/01_basic.t
+++ b/lib/Thread/Queue/t/01_basic.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);
     }
 }
@@ -129,4 +129,6 @@ is($q->pending(), 1, 'Queue count after thread');
 is($q->dequeue(), 'done', 'Thread reported done');
 is($q->pending(), 0, 'Empty queue');
 
+exit(0);
+
 # EOF
diff --git a/lib/Thread/Queue/t/02_refs.t b/lib/Thread/Queue/t/02_refs.t
index 6ea63e8c89..3a59b5e3b6 100644
--- a/lib/Thread/Queue/t/02_refs.t
+++ b/lib/Thread/Queue/t/02_refs.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);
     }
 }
@@ -184,4 +184,6 @@ is($$obj2{'frowny'}, ':(', 'Shared object changed');
 is($$sref1, 'foo', 'Scalar ref unchanged');
 is($$sref2, 'zzz', 'Shared scalar ref changed');
 
+exit(0);
+
 # EOF
diff --git a/lib/Thread/Queue/t/03_peek.t b/lib/Thread/Queue/t/03_peek.t
index faa634d9ce..1844c06dea 100644
--- a/lib/Thread/Queue/t/03_peek.t
+++ b/lib/Thread/Queue/t/03_peek.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);
     }
 }
@@ -51,4 +51,6 @@ threads->create(sub {
 })->join();
 q_check();
 
+exit(0);
+
 # EOF
diff --git a/lib/Thread/Queue/t/04_errs.t b/lib/Thread/Queue/t/04_errs.t
index 00132d7836..3479c83c9e 100644
--- a/lib/Thread/Queue/t/04_errs.t
+++ b/lib/Thread/Queue/t/04_errs.t
@@ -70,4 +70,6 @@ like($@, qr/Invalid 'count'/, $@);
 eval { $q->extract(0, 'foo'); };
 like($@, qr/Invalid 'count'/, $@);
 
+exit(0);
+
 # EOF
diff --git a/lib/Thread/Queue/t/05_extract.t b/lib/Thread/Queue/t/05_extract.t
index 8c2fb2f304..2773340932 100644
--- a/lib/Thread/Queue/t/05_extract.t
+++ b/lib/Thread/Queue/t/05_extract.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);
     }
 }
@@ -73,4 +73,6 @@ threads->create(sub {
     is_deeply(\@x, [4..6], 'Neg big overlap');
 })->join();
 
+exit(0);
+
 # EOF
diff --git a/lib/Thread/Queue/t/06_insert.t b/lib/Thread/Queue/t/06_insert.t
index 77543832a9..4f9c2b47ec 100644
--- a/lib/Thread/Queue/t/06_insert.t
+++ b/lib/Thread/Queue/t/06_insert.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);
     }
 }
@@ -101,4 +101,6 @@ threads->create(sub {
 @x = $q->dequeue_nb(100);
 is_deeply(\@x, [1,'foo',2,3], 'Empty queue insert');
 
+exit(0);
+
 # EOF
diff --git a/lib/Thread/Queue/t/07_lock.t b/lib/Thread/Queue/t/07_lock.t
index 4fc407e0be..625159e97c 100644
--- a/lib/Thread/Queue/t/07_lock.t
+++ b/lib/Thread/Queue/t/07_lock.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);
     }
 }
@@ -51,4 +51,6 @@ my @x = $q->dequeue_nb(100);
 is_deeply(\@x, [1..5,8..10], 'Main dequeues');
 threads::yield();
 
+exit(0);
+
 # EOF
diff --git a/lib/Thread/Queue/t/08_nothreads.t b/lib/Thread/Queue/t/08_nothreads.t
index 375d031fab..7ac43481b3 100644
--- a/lib/Thread/Queue/t/08_nothreads.t
+++ b/lib/Thread/Queue/t/08_nothreads.t
@@ -109,4 +109,6 @@ is($q->pending(), 7, 'Queue count');
 # Check results of thread's activities
 is($q->pending(), 0, 'Empty queue');
 
+exit(0);
+
 # EOF