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
|
#!/usr/bin/env perl
use strict;
use warnings;
use utf8;
use open qw(:std :utf8);
use Test::More;
# Non-blocking tests (dequeue_nb and recv_nb) were disabled
# in MCE 1.884 for the Windows platform; copied here in xt.
# The following tests pass on Windows, typically.
BEGIN {
if ( $^O eq 'cygwin' ) {
plan skip_all => "MCE::Channel::Threads not used on Cygwin";
}
eval 'use threads'; ## no critic
plan skip_all => "threads not available" if $@;
use_ok 'MCE::Channel';
use_ok 'MCE::Channel::Simple';
use_ok 'MCE::Channel::SimpleFast';
use_ok 'MCE::Channel::Threads';
use_ok 'MCE::Channel::ThreadsFast';
}
# https://sacred-texts.com/cla/usappho/sph02.htm (III)
my $sappho_text =
"ἄρμ᾽ ὐποζεύξαια, κάλοι δέ σ᾽ ἆγον
ὤκεεσ στροῦθοι περὶ γᾶσ μελαίνασ
πύκνα δινεῦντεσ πτέῤ ἀπ᾽ ὠράνω
αἴθεροσ διὰ μέσσω.";
my $translation =
"With chariot yoked to thy fleet-winged coursers,
Fluttering swift pinions over earth's darkness,
And bringing thee through the infinite, gliding
Downwards from heaven.";
my $come_then_i_pray = "さあ、私は祈る" . "Ǣ";
my $chnl1 = MCE::Channel->new( impl => 'Simple' );
is $chnl1->impl(), 'Simple', 'implementation name';
my $chnl2 = MCE::Channel->new( impl => 'Threads' );
is $chnl2->impl(), 'Threads', 'implementation name';
my $chnl3 = MCE::Channel->new( impl => 'SimpleFast' );
is $chnl3->impl(), 'SimpleFast', 'implementation name';
my $chnl4 = MCE::Channel->new( impl => 'ThreadsFast' );
is $chnl4->impl(), 'ThreadsFast', 'implementation name';
# send recv_nb
for my $chnl ($chnl1, $chnl2)
{
$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';
}
for my $chnl ($chnl3, $chnl4)
{
$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_nb
for my $chnl ($chnl1, $chnl2)
{
$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';
}
for my $chnl ($chnl3, $chnl4)
{
$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_nb
for my $chnl ($chnl1, $chnl2)
{
$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';
}
for my $chnl ($chnl3, $chnl4)
{
$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';
}
done_testing;
|
