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
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
#!/usr/bin/env perl
use strict;
use warnings;
use utf8;
use open qw(:std :utf8);
use Test::More;
BEGIN {
plan skip_all => "Not used on Cygwin" if ( $^O eq 'cygwin' );
if ( $] lt '5.010001' && $^O ne 'MSWin32' ) {
plan skip_all => "old Perl and threads not supported on Unix platforms";
}
eval 'use threads'; ## no critic
plan skip_all => "threads not available" if $@;
use_ok 'MCE::Channel';
use_ok 'MCE::Channel::Threads';
}
## https://sacred-texts.com/cla/usappho/sph02.htm (IV)
my $sappho_text =
"αῖψα δ᾽ ἐχίκοντο, σὺ δ᾽, ὦ μάσαιρα
μειδιάσαισ᾽ ἀθάνατῳ προσώπῳ,
ἤρἐ ὄττι δηὖτε πέπονθα κὤττι
δἦγτε κάλημι.";
my $translation =
"Then, soon they arrived and thou, blessed goddess,
With divine contenance smiling, didst ask me
What new woe had befallen me now and why,
Thus I had called the.";
my $come_then_i_pray = "さあ、私は祈る" . "Ǣ";
my $chnl = MCE::Channel->new( impl => 'Threads', mp => 1 );
is $chnl->impl(), 'Threads', 'implementation name';
# send recv
{
$chnl->send('a string');
is $chnl->recv, 'a string', 'send recv scalar';
$chnl->send($sappho_text);
is $chnl->recv, $sappho_text, 'send recv utf8';
$chnl->send($come_then_i_pray);
is $chnl->recv, $come_then_i_pray, 'send recv utf8_ja';
$chnl->send(qw/ a list of arguments /);
is scalar( my @args = $chnl->recv ), 4, 'send recv list';
$chnl->send({ complex => 'structure' });
is ref( $chnl->recv ), 'HASH', 'send recv complex';
}
# send recv_nb
if ($^O ne 'MSWin32')
{
$chnl->send('a string');
is $chnl->recv_nb, 'a string', 'send recv_nb scalar';
$chnl->send($sappho_text);
is $chnl->recv_nb, $sappho_text, 'send recv_nb utf8';
$chnl->send($come_then_i_pray);
is $chnl->recv_nb, $come_then_i_pray, 'send recv_nb utf8_ja';
$chnl->send(qw/ a list of arguments /);
is scalar( my @args = $chnl->recv_nb ), 4, 'send recv_nb list';
$chnl->send({ complex => 'structure' });
is ref( $chnl->recv_nb ), 'HASH', 'send recv_nb complex';
}
# send2 recv2
{
$chnl->send2('a string');
is $chnl->recv2, 'a string', 'send2 recv2 scalar';
$chnl->send2($sappho_text);
is $chnl->recv2, $sappho_text, 'send2 recv2 utf8';
$chnl->send2($come_then_i_pray);
is $chnl->recv2, $come_then_i_pray, 'send2 recv2 utf8_ja';
$chnl->send2(qw/ a list of arguments /);
is scalar( my @args = $chnl->recv2 ), 4, 'send2 recv2 list';
$chnl->send2({ complex => 'structure' });
is ref( $chnl->recv2 ), 'HASH', 'send2 recv2 complex';
}
# send2 recv2_nb
if ($^O ne 'MSWin32')
{
$chnl->send2('a string');
is $chnl->recv2_nb, 'a string', 'send2 recv2_nb scalar';
$chnl->send2($sappho_text);
is $chnl->recv2_nb, $sappho_text, 'send2 recv2_nb utf8';
$chnl->send2($come_then_i_pray);
is $chnl->recv2_nb, $come_then_i_pray, 'send2 recv2_nb utf8_ja';
$chnl->send2(qw/ a list of arguments /);
is scalar( my @args = $chnl->recv2_nb ), 4, 'send2 recv2_nb list';
$chnl->send2({ complex => 'structure' });
is ref( $chnl->recv2_nb ), 'HASH', 'send2 recv2_nb complex';
}
# enqueue dequeue
{
$chnl->enqueue('a string');
is $chnl->dequeue, 'a string', 'enqueue dequeue scalar';
$chnl->enqueue($sappho_text);
is $chnl->dequeue, $sappho_text, 'enqueue dequeue utf8';
$chnl->enqueue($come_then_i_pray);
is $chnl->dequeue, $come_then_i_pray, 'enqueue dequeue utf8_ja';
$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({ complex => 'structure' });
is ref( $chnl->dequeue ), 'HASH', 'enqueue dequeue complex';
$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($sappho_text);
is $chnl->dequeue_nb, $sappho_text, 'enqueue dequeue_nb utf8';
$chnl->enqueue($come_then_i_pray);
is $chnl->dequeue_nb, $come_then_i_pray, 'enqueue dequeue_nb utf8_ja';
$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({ complex => 'structure' });
is ref( $chnl->dequeue_nb ), 'HASH', 'enqueue dequeue_nb complex';
$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;
|
