ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Coro/Event/Event.pm
(Generate patch)

Comparing Coro/Event/Event.pm (file contents):
Revision 1.13 by root, Sat Mar 22 18:50:32 2003 UTC vs.
Revision 1.41 by root, Fri Dec 1 02:17:37 2006 UTC

… …
6 6
7 use Coro; 7 use Coro;
8 use Coro::Event; 8 use Coro::Event;
9 9
10 sub keyboard : Coro { 10 sub keyboard : Coro {
11 my $w = Coro::Event->io(fd => *STDIN, poll => 'r'); 11 my $w = Coro::Event->io(fd => \*STDIN, poll => 'r');
12 while() { 12 while() {
13 print "cmd> "; 13 print "cmd> ";
14 my $ev = $w->next; my $cmd = <STDIN>; 14 my $ev = $w->next; my $cmd = <STDIN>;
15 unloop unless $cmd ne ""; 15 unloop unless $cmd ne "";
16 print "data> "; 16 print "data> ";
… …
32function - it will be managed by this module. 32function - it will be managed by this module.
33 33
34Your application should just create all necessary coroutines and then call 34Your application should just create all necessary coroutines and then call
35Coro::Event::loop. 35Coro::Event::loop.
36 36
37Please note that even programs or modules (such as
38L<Coro::Handle|Coro::Handle>) that use "traditional"
39event-based/continuation style will run more efficient with this module
40then when using only Event.
41
37=over 4 42=over 4
38 43
39=cut 44=cut
40 45
41package Coro::Event; 46package Coro::Event;
42 47
43no warnings qw(uninitialized); 48BEGIN { eval { require warnings } && warnings->unimport ("uninitialized") }
44 49
45use Carp; 50use Carp;
51no warnings;
46 52
47use Coro; 53use Coro;
54use Coro::Timer;
48use Event qw(loop unloop); # we are re-exporting this, cooool! 55use Event qw(loop unloop); # we are re-exporting this, cooool!
49 56
50use base 'Exporter'; 57use XSLoader;
51 58
59use base Exporter::;
60
52@EXPORT = qw(loop unloop sweep reschedule); 61our @EXPORT = qw(loop unloop sweep);
53 62
54BEGIN { 63BEGIN {
55 $VERSION = 0.6; 64 our $VERSION = 1.9;
56 65
57 local $^W = 0; # avoid redefine warning for Coro::ready; 66 local $^W = 0; # avoid redefine warning for Coro::ready;
58 require XSLoader;
59 XSLoader::load Coro::Event, $VERSION; 67 XSLoader::load __PACKAGE__, $VERSION;
60} 68}
61 69
62=item $w = Coro::Event->flavour(args...) 70=item $w = Coro::Event->flavour(args...)
63 71
64Create and return a watcher of the given type. 72Create and return a watcher of the given type.
… …
107 }; 115 };
108 *{ $flavour } = $coronew; 116 *{ $flavour } = $coronew;
109 *{"do_$flavour"} = sub { 117 *{"do_$flavour"} = sub {
110 unshift @_, Coro::Event::; 118 unshift @_, Coro::Event::;
111 my $e = (&$coronew)->next; 119 my $e = (&$coronew)->next;
112 $e->cancel; # $e = $e->w->cancel ($e == $e->w!) 120 $e->cancel; # $e === $e->w
113 $e; 121 $e;
114 }; 122 };
115} 123}
116 124
117# double calls to avoid stack-cloning ;() 125# double calls to avoid stack-cloning ;()
118# is about 10% slower, though. 126# is about 10% slower, though.
119sub next($) { 127sub next($) {
120 &Coro::schedule if &_next; $_[0]; 128 &Coro::schedule while &_next;
129
130 $_[0]
121} 131}
122 132
123sub Coro::Event::w { $_[0] } 133sub Coro::Event::w { $_[0] }
124sub Coro::Event::prio { $_[0]{Coro::Event}[3] } 134sub Coro::Event::prio { $_[0]{Coro::Event}[3] }
125sub Coro::Event::hits { $_[0]{Coro::Event}[4] } 135sub Coro::Event::hits { $_[0]{Coro::Event}[4] }
… …
146 156
147This is the version of C<loop> you should use instead of C<Event::loop> 157This is the version of C<loop> you should use instead of C<Event::loop>
148when using this module - it will ensure correct scheduling in the presence 158when using this module - it will ensure correct scheduling in the presence
149of events. 159of events.
150 160
151=begin comment
152
153Unlike loop's counterpart it is not an error when no watchers are active -
154loop silently returns in this case, as if unloop(undef) were called.
155
156=end comment
157
158=cut
159
160# no longer do something special - it's done internally now
161
162#sub loop(;$) {
163# #local $Coro::idle = $Coro::current;
164# #Coro::schedule; # become idle task, which is implicitly ready
165# &Event::loop;
166#}
167
168=item unloop([$result]) 161=item unloop([$result])
169 162
170Same as Event::unloop (provided here for your convinience only). 163Same as Event::unloop (provided here for your convinience only).
171 164
172=cut 165=cut
173 166
174$Coro::idle = new Coro sub { 167$Coro::idle = \&Event::one_event; # inefficient
175 while () {
176 Event::one_event; # inefficient
177 Coro::schedule;
178 }
179};
180
181# provide hooks for Coro::Timer
182
183package Coro::Timer;
184
185unless ($override) {
186 $override = 1;
187 *_new_timer = sub {
188 Event->timer(at => $_[0], cb => $_[1]);
189 };
190}
191 168
1921; 1691;
193 170
171=back
172
194=head1 AUTHOR 173=head1 AUTHOR
195 174
196 Marc Lehmann <pcg@goof.com> 175 Marc Lehmann <schmorp@schmorp.de>
197 http://www.goof.com/pcg/marc/ 176 http://home.schmorp.de/
198 177
199=cut 178=cut
200 179

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines