Login or Register to Ask a Question and Join Our Community

Linux and UNIX Man Pages

Linux & Unix Commands - Search Man Pages

anyevent::forkobject(3pm) [debian man page]

AnyEvent::ForkObject(3pm)				User Contributed Perl Documentation				 AnyEvent::ForkObject(3pm)

NAME

       AnyEvent::ForkObject - Async access on objects.

SYNOPSIS

	   use AnyEvent::ForkObject;
	   use DBI;

	   my $fo = new AnyEvent::ForkObject;

	   $fo->do(
	       module => 'DBI',
	       method => 'connect',
	       args => [ 'dbi:mysql...' ],
	       cb => sub {
		   my ($status, $dbh) = @_;

		   $dbh->selectrow_array('SELECT ?', undef, 1 + 1, sub {
		       my ($status, $result) = @_;
		       print "$result
";   # prints 2
		   });
	       }
	   );

	   use AnyEvent::Tools qw(async_repeat);

	   $dbh->prepare('SELECT * FROM tbl', sub {
	       my ($status, $sth) = @_;
	       $sth->execute(sub {
		   my ($status, $rv) = @_;

		   # fetch 30 rows
		   async_repeat 30 => sub {
		       my ($guard) = @_;

		       $sth->fetchrow_hashref(sub {
			   my ($status, $row) = @_;
			   undef $guard;

			   # do something with $row
		       });
		   };

	       });
	   });

DESCRIPTION

       There are a lot of modules that provide object interface. Using the module You can use them in async mode.

METHODS

   new
       Constructor. Creates an instance that contains fork jail.

   do
       Creates an object inside jail. It receives the following named arguments:

       require
	   Do require inside jail. If the argument is exists, module, method and wantarray arguments will be ignored.

       module
	   Module name. For example 'DBI'.

       method
	   Constructor name. Default value is 'new'.

       wantarray
	   Context for method. Default is 0 (SCALAR).

       cb  Done callback. The first argument is a status:

	   die The method has thrown exception. The next argument contains $@.

	   fatal
	       A fatal error was occured (for example fork jail was killed).

	   ok  Method has done. The following arguments contain all data that were returned by the method.

       If "method" returns blessed object, it will provide all its methods in modified form. Each method will receive one or two additional
       arguments:

       result callback
	   A callback that will be called after method has done.

       wantarray
	   Context flag for method. Default value is 0 (SCALAR).

       All objects provide additional method fo_attr to access their field.  Example:

	   # set attribute
	   $dbh->fo_attr(RaiseError => 1, sub { my ($status, $attr) = @_; ... });

	   # get attribute
	   $dbh->fo_attr('RaiseError', sub { my ($status, $attr) = @_; ... });

AUTHOR

       Dmitry E. Oboukhov, <unera@debian.org>

COPYRIGHT AND LICENSE

       Copyright (C) 2011 by Dmitry E. Oboukhov

       This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself, either Perl version 5.10.1 or,
       at your option, any later version of Perl 5 you may have available.

VCS

       The project is placed in my git repo: http://git.uvw.ru/?p=anyevent-forkobject;a=summary <http://git.uvw.ru/?p=anyevent-
       forkobject;a=summary>

perl v5.12.4							    2011-07-29						 AnyEvent::ForkObject(3pm)

Check Out this Related Man Page

AnyEvent::Serialize(3pm)				User Contributed Perl Documentation				  AnyEvent::Serialize(3pm)

NAME

       AnyEvent::Serialize - async serialize/deserialize function

SYNOPSIS

	 use AnyEvent::Serialize ':all';
	 use AnyEvent::Serialize 'serialize';
	 use AnyEvent::Serialize 'deserialize';
	 use AnyEvent::Serialize ... block_size => 666;

	 serialize $object, sub { ($str, $recursion_detected) = @_ };
	 deserialize $string, sub { my ($object, $error, $tail) = @_ }

DESCRIPTION

       Sometimes You need to serialize/deserialize a lot of data. If You do it using Data::Dumper or eval it can take You too much time.  This
       module splits (de)serialization process into fixed-size parts and does this work in non-blocking mode.

       This module uses Data::StreamSerializer and Data::StreamDeserializer to serialize or deserialize Your data.

EXPORT

   serialize($object, $result_callback)
       Serializes Your object. When serialization is done it will call $result_callback. This callback receives two arguments:

       result string
       flag if recursion is detected

   deserialize($str, $result_callback)
       Deserializes Your string. When deserialization is done or an error is detected it will call $result_callback. This callback receives three
       arguments:

       deserialized object
       error string (if an error was occured)
       undeserialized string tail

BREAKING

       You can break serialization/deserialization process if You save value that is returned by functions serialize/deserialize. They return
       guards if they are called in non-void context.

SEE ALSO

       Data::StreamSerializer, Data::StreamDeserializer.

AUTHOR

       Dmitry E. Oboukhov, <unera@debian.org>

COPYRIGHT AND LICENSE

       Copyright (C) 2011 by Dmitry E. Oboukhov

       This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself, either Perl version 5.10.1 or,
       at your option, any later version of Perl 5 you may have available.

perl v5.10.1							    2011-03-02						  AnyEvent::Serialize(3pm)
Man Page