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
|
#!/usr/bin/env perl
use strict;
use warnings;
use Test::More;
use Time::HiRes 'time';
use MCE::Mutex;
my $mutex = MCE::Mutex->new( impl => 'Channel2' );
is($mutex->impl(), 'Channel2', 'implementation name');
sub task {
$mutex->lock_exclusive;
sleep(1) for 1..5;
$mutex->unlock;
}
sub task2 {
$mutex->lock_exclusive2;
sleep(1) for 1..5;
$mutex->unlock2;
}
sub spawn {
my $pid = fork;
task(), exit() if $pid == 0;
return $pid;
}
sub spawn2 {
my $pid = fork;
task2(), exit() if $pid == 0;
return $pid;
}
{
my $pid = spawn(); sleep 1;
my $start = time; my $ret = $mutex->timedwait(2);
my $end = time;
waitpid($pid, 0);
my $success = ($end - $start < 3) ? 1 : 0;
is($success, 1, 'mutex timedwait');
is($ret, '', 'mutex timedwait value');
}
{
my $pid = spawn2(); sleep 1;
my $start = time; my $ret = $mutex->timedwait2(2);
my $end = time;
waitpid($pid, 0);
my $success = ($end - $start < 3) ? 1 : 0;
is($success, 1, 'mutex timedwait2');
is($ret, '', 'mutex timedwait2 value');
}
done_testing;
|
