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
|
#!/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 MSWin32" if ( $^O eq 'MSWin32' );
use_ok 'MCE::Channel';
use_ok 'MCE::Channel::Mutex';
}
## https://sacred-texts.com/cla/usappho/sph02.htm (II)
my $sappho_text =
"ἀλλά τυίδ᾽ ἔλθ᾽, αἴποτα κἀτέρωτα
τᾶσ ἔμασ αύδωσ αἴοισα πήλγι
ἔκλυεσ πάτροσ δὲ δόμον λίποισα
χρύσιον ἦλθεσ.";
my $translation =
"Whenever before thou has hearkened to me--
To my voice calling to thee in the distance,
And heeding, thou hast come, leaving thy father's
Golden dominions.";
my $come_then_i_pray = "さあ、私は祈る" . "Ǣ";
my $chnl = MCE::Channel->new( impl => 'Mutex' );
is $chnl->impl, 'Mutex', '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
{
$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
{
$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
{
$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
{
$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;
|