1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
#!perl -T
use strict;
use warnings;
sub skipall {
my ($msg) = @_;
require Test::More;
Test::More::plan(skip_all => $msg);
}
use Config qw/%Config/;
BEGIN {
skipall 'This perl wasn\'t built to support threads'
unless $Config{useithreads};
skipall 'threads required to test thread safety' unless eval "use threads; 1";
}
use Test::More;
use Scope::Upper qw/unwind UP SU_THREADSAFE/;
my $num;
BEGIN {
skipall 'This Scope::Upper isn\'t thread safe' unless SU_THREADSAFE;
plan tests => ($num = 30);
defined and diag "Using threads $_" for $threads::VERSION;
if (eval "use Time::HiRes; 1") {
defined and diag "Using Time::HiRes $_" for $Time::HiRes::VERSION;
*usleep = \&Time::HiRes::usleep;
} else {
diag 'Using fallback usleep';
*usleep = sub {
my $s = int($_[0] / 2.5e5);
sleep $s if $s;
};
}
}
our $z;
sub up1 {
my $tid = threads->tid();
local $z = $tid;
my $p = "[$tid] up1";
usleep rand(1e6);
my @res = (
-1,
sub {
my @dummy = (
999,
sub {
my $foo = unwind $tid .. $tid + 2 => UP;
fail "$p: not reached";
}->()
);
fail "$p: not reached";
}->(),
-2
);
is_deeply \@res, [ -1, $tid .. $tid + 2, -2 ], "$p: unwinded correctly";
}
$_->join for map threads->create(\&up1), 1 .. $num;
|
