Coro/EV/EV.pm

=head1 NAME

Coro::EV - do events the coro-way

=head1 SYNOPSIS

 use Coro;
 use Coro::EV;

 EV::loop;

=head1 DESCRIPTION

This module does two things: First, it offers some utility functions that
might be useful for coroutines, and secondly, it integrates Coro into the
EV main loop:

Before the process blocks (in EV::loop) to wait for events, this module
will schedule and run all ready (= runnable) coroutines of the same or
higher priority. After that, it will cede once to a coroutine of lower
priority, then continue in the event loop.

That means that coroutines with the same or higher pripority as the
coroutine running the main loop will inhibit event processing, while
coroutines of lower priority will get the CPU, but cannot completeley
inhibit event processing.

=head2 RUNNING WITH OR WITHOUT A MAINLOOP

In general, you should always run EV::loop, either in your main program,
or in a separate coroutine. If you don't do that and all coroutines start
waiting for some events, this module will run the event loop once, but
this is very inefficient.

=head1 FUNCTIONS

=over 4

=cut

package Coro::EV;

no warnings;
use strict;

use Carp;
no warnings;

use Coro;

use EV ();
use XSLoader;

BEGIN {
   our $VERSION = "5.0";

   local $^W = 0; # avoid redefine warning for Coro::ready;
   XSLoader::load __PACKAGE__, $VERSION;
}

our $IDLE = new Coro sub {
   while () {
      &_loop_oneshot;
      &Coro::schedule;
   }
};
$IDLE->{desc} = "[EV idle process]";

$Coro::idle = sub { $IDLE->ready };

=item $revents = Coro::EV::timed_io_once $fileno_or_fh, $events, $timeout

Blocks the coroutine until either the given event set has occured on the
fd, or the timeout has been reached (if timeout is zero, there is no
timeout). Returns the received flags.

=item Coro::EV::timer_once $after

Blocks the coroutine for at least C<$after> seconds.

=cut

1;

=back

=head1 AUTHOR

 Marc Lehmann <schmorp@schmorp.de>
 http://home.schmorp.de/

=cut

Revision:	1.30
Committed:	Thu Nov 20 09:37:21 2008 UTC (15 years, 6 months ago) by root
Branch:	MAIN
CVS Tags:	rel-5_0
Changes since 1.29:	+1 -1 lines
Log Message:	5.0
#	User	Rev	Content
1	root	1.1	=head1 NAME
2
3			Coro::EV - do events the coro-way
4
5			=head1 SYNOPSIS
6
7			use Coro;
8			use Coro::EV;
9
10	root	1.5	EV::loop;
11
12	root	1.4	=head1 DESCRIPTION
13	root	1.1
14	root	1.4	This module does two things: First, it offers some utility functions that
15			might be useful for coroutines, and secondly, it integrates Coro into the
16			EV main loop:
17
18			Before the process blocks (in EV::loop) to wait for events, this module
19			will schedule and run all ready (= runnable) coroutines of the same or
20			higher priority. After that, it will cede once to a coroutine of lower
21			priority, then continue in the event loop.
22
23			That means that coroutines with the same or higher pripority as the
24			coroutine running the main loop will inhibit event processing, while
25			coroutines of lower priority will get the CPU, but cannot completeley
26			inhibit event processing.
27	root	1.1
28	root	1.5	=head2 RUNNING WITH OR WITHOUT A MAINLOOP
29
30			In general, you should always run EV::loop, either in your main program,
31			or in a separate coroutine. If you don't do that and all coroutines start
32			waiting for some events, this module will run the event loop once, but
33			this is very inefficient.
34
35	root	1.1	=head1 FUNCTIONS
36
37			=over 4
38
39			=cut
40
41			package Coro::EV;
42
43			no warnings;
44	root	1.8	use strict;
45	root	1.1
46			use Carp;
47			no warnings;
48
49			use Coro;
50
51			use EV ();
52			use XSLoader;
53
54			BEGIN {
55	root	1.30	our $VERSION = "5.0";
56	root	1.1
57			local $^W = 0; # avoid redefine warning for Coro::ready;
58			XSLoader::load __PACKAGE__, $VERSION;
59			}
60
61	root	1.8	our $IDLE = new Coro sub {
62			while () {
63			&_loop_oneshot;
64			&Coro::schedule;
65			}
66			};
67			$IDLE->{desc} = "[EV idle process]";
68	root	1.1
69	root	1.8	$Coro::idle = sub { $IDLE->ready };
70	root	1.1
71	root	1.11	=item $revents = Coro::EV::timed_io_once $fileno_or_fh, $events, $timeout
72	root	1.3
73			Blocks the coroutine until either the given event set has occured on the
74			fd, or the timeout has been reached (if timeout is zero, there is no
75			timeout). Returns the received flags.
76
77			=item Coro::EV::timer_once $after
78
79			Blocks the coroutine for at least C<$after> seconds.
80
81			=cut
82
83	root	1.1	1;
84
85			=back
86
87			=head1 AUTHOR
88
89			Marc Lehmann <schmorp@schmorp.de>
90			http://home.schmorp.de/
91
92			=cut
93