AnyEvent-Fork-RPC
view release on metacpan or search on metacpan
memory sharing, then you should load "AnyEvent::Fork::RPC::Sync"
for synchronous, and "AnyEvent::Fork::RPC::Async" for
asynchronous mode.
If you use a template process and want to fork both sync and
async children, then it is permissible to load both modules.
serialiser => $string (default:
$AnyEvent::Fork::RPC::STRING_SERIALISER)
All arguments, result data and event data have to be serialised
to be transferred between the processes. For this, they have to
be frozen and thawed in both parent and child processes.
By default, only octet strings can be passed between the
processes, which is reasonably fast and efficient and requires
no extra modules (the "AnyEvent::Fork::RPC" distribution does
not provide these extra serialiser modules).
For more complicated use cases, you can provide your own freeze
and thaw functions, by specifying a string with perl source
code. It's supposed to return two code references when
evaluated: the first receives a list of perl values and must
return an octet string. The second receives the octet string and
must return the original list of values.
If you need an external module for serialisation, then you can
either pre-load it into your AnyEvent::Fork process, or you can
add a "use" or "require" statement into the serialiser string.
Or both.
Here are some examples - all of them are also available as
global variables that make them easier to use.
$AnyEvent::Fork::RPC::STRING_SERIALISER - octet strings only
This serialiser (currently the default) concatenates
length-prefixes octet strings, and is the default. That
means you can only pass (and return) strings containing
character codes 0-255.
The main advantages of this serialiser are the high speed
and that it doesn't need another module. The main
disadvantage is that you are very limited in what you can
pass - only octet strings.
Implementation:
(
sub { pack "(w/a*)*", @_ },
sub { unpack "(w/a*)*", shift }
)
$AnyEvent::Fork::RPC::CBOR_XS_SERIALISER - uses CBOR::XS
This serialiser creates CBOR::XS arrays - you have to make
sure the CBOR::XS module is installed for this serialiser to
work. It can be beneficial for sharing when you preload the
CBOR::XS module in a template process.
CBOR::XS is about as fast as the octet string serialiser,
but supports complex data structures (similar to JSON) and
is faster than any of the other serialisers. If you have the
CBOR::XS module available, it's the best choice.
The encoder enables "allow_sharing" (so this serialisation
method can encode cyclic and self-referencing data
structures).
Implementation:
use CBOR::XS ();
(
sub { CBOR::XS::encode_cbor_sharing \@_ },
sub { @{ CBOR::XS::decode_cbor shift } }
)
$AnyEvent::Fork::RPC::JSON_SERIALISER - uses JSON::XS or JSON
This serialiser creates JSON arrays - you have to make sure
the JSON module is installed for this serialiser to work. It
can be beneficial for sharing when you preload the JSON
module in a template process.
JSON (with JSON::XS installed) is slower than the octet
string serialiser, but usually much faster than Storable,
unless big chunks of binary data need to be transferred.
Implementation:
use JSON ();
(
sub { JSON::encode_json \@_ },
sub { @{ JSON::decode_json shift } }
)
$AnyEvent::Fork::RPC::STORABLE_SERIALISER - Storable
This serialiser uses Storable, which means it has high
chance of serialising just about anything you throw at it,
at the cost of having very high overhead per operation. It
also comes with perl. It should be used when you need to
serialise complex data structures.
Implementation:
use Storable ();
(
sub { Storable::freeze \@_ },
sub { @{ Storable::thaw shift } }
)
$AnyEvent::Fork::RPC::NSTORABLE_SERIALISER - portable Storable
This serialiser also uses Storable, but uses it's "network"
format to serialise data, which makes it possible to talk to
different perl binaries (for example, when talking to a
process created with AnyEvent::Fork::Remote).
Implementation:
use Storable ();
(
sub { Storable::nfreeze \@_ },
sub { @{ Storable::thaw shift } }
)
( run in 1.176 second using v1.01-cache-2.11-cpan-39bf76dae61 )