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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
#!/usr/bin/env perl
use strict;
use warnings;
use Test::More;
BEGIN {
use_ok 'MCE::Channel';
use_ok 'MCE::Channel::SimpleFast';
}
my $chnl = MCE::Channel->new( impl => 'SimpleFast' );
is $chnl->impl(), 'SimpleFast', 'implementation name';
# send recv
{
$chnl->send('a string');
is $chnl->recv, 'a string', 'send recv scalar';
$chnl->send('');
is $chnl->recv, '', 'send recv blank string';
$chnl->send(undef);
is $chnl->recv, '', 'send recv undef stringified';
}
# send recv_nb
if ($^O ne 'MSWin32')
{
$chnl->send('a string');
is $chnl->recv_nb, 'a string', 'send recv_nb scalar';
$chnl->send('');
is $chnl->recv_nb, '', 'send recv_nb blank string';
$chnl->send(undef);
is $chnl->recv_nb, '', 'send recv_nb undef stringified';
}
# send2 recv2
{
$chnl->send2('a string');
is $chnl->recv2, 'a string', 'send2 recv2 scalar';
$chnl->send2('');
is $chnl->recv2, '', 'send2 recv2 blank string';
$chnl->send2(undef);
is $chnl->recv2, '', 'send2 recv2 undef stringified';
}
# send2 recv2_nb
if ($^O ne 'MSWin32')
{
$chnl->send2('a string');
is $chnl->recv2_nb, 'a string', 'send2 recv2_nb scalar';
$chnl->send2('');
is $chnl->recv2_nb, '', 'send2 recv2_nb blank string';
$chnl->send2(undef);
is $chnl->recv2_nb, '', 'send2 recv2_nb undef stringified';
}
# enqueue dequeue
{
$chnl->enqueue('a string');
is $chnl->dequeue, 'a string', 'enqueue dequeue scalar';
$chnl->enqueue(qw/ a list of items /);
is scalar( my $item1 = $chnl->dequeue ), 'a', 'enqueue dequeue item1';
is scalar( my $item2 = $chnl->dequeue ), 'list', 'enqueue dequeue item2';
is scalar( my $item3 = $chnl->dequeue ), 'of', 'enqueue dequeue item3';
is scalar( my $item4 = $chnl->dequeue ), 'items', 'enqueue dequeue item4';
$chnl->enqueue('');
is $chnl->dequeue, '', 'enqueue dequeue blank string';
$chnl->enqueue(undef);
is $chnl->dequeue, '', 'enqueue dequeue undef stringified';
$chnl->enqueue(qw/ a b c /);
is join( '', $chnl->dequeue(3) ), 'abc', 'enqueue dequeue count';
}
# enqueue dequeue_nb
if ($^O ne 'MSWin32')
{
$chnl->enqueue('a string');
is $chnl->dequeue_nb, 'a string', 'enqueue dequeue_nb scalar';
$chnl->enqueue(qw/ a list of items /);
is scalar( my $item1 = $chnl->dequeue_nb ), 'a', 'enqueue dequeue_nb item1';
is scalar( my $item2 = $chnl->dequeue_nb ), 'list', 'enqueue dequeue_nb item2';
is scalar( my $item3 = $chnl->dequeue_nb ), 'of', 'enqueue dequeue_nb item3';
is scalar( my $item4 = $chnl->dequeue_nb ), 'items', 'enqueue dequeue_nb item4';
$chnl->enqueue('');
is $chnl->dequeue_nb, '', 'enqueue dequeue_nb blank string';
$chnl->enqueue(undef);
is $chnl->dequeue_nb, '', 'enqueue dequeue_nb undef stringified';
$chnl->enqueue(qw/ a b c /);
is join( '', $chnl->dequeue_nb(3) ), 'abc', 'enqueue dequeue_nb count';
}
# end
if ($^O ne 'MSWin32')
{
$chnl->enqueue("item $_") for 1 .. 2;
$chnl->end;
for my $method (qw/ send enqueue /) {
local $SIG{__WARN__} = sub {
is $_[0],
"WARNING: ($method) called on a channel that has been 'end'ed\n",
"channel ended, $method";
};
$chnl->$method("item");
}
is $chnl->dequeue_nb, 'item 1', 'channel ended, dequeue_nb item 1';
is $chnl->dequeue_nb, 'item 2', 'channel ended, dequeue_nb item 2';
}
done_testing;
|
