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.10 by root, Mon Feb 18 21:25:02 2002 UTC vs.
Revision 1.42 by root, Fri Dec 1 02:24:46 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> ";
… …
30(I<flavour>) (see L<Event>). The only difference between these and the 30(I<flavour>) (see L<Event>). The only difference between these and the
31watcher constructors from Event is that you do not specify a callback 31watcher constructors from Event is that you do not specify a callback
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->main. 35Coro::Event::loop.
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
42=head1 WARNING
43
44Please note that Event does not support coroutines or threads. That
45means that you B<MUST NOT> block in an event callback. Again: In Event
46callbacks, you I<must never ever> call a Coroutine fucntion that blocks
47the current coroutine.
48
49While this seems to work superficially, it will eventually cause memory
50corruption.
51
52=head1 FUNCTIONS
36 53
37=over 4 54=over 4
38 55
39=cut 56=cut
40 57
41package Coro::Event; 58package Coro::Event;
42 59
43no warnings qw(uninitialized); 60no warnings;
44 61
45use Carp; 62use Carp;
63no warnings;
46 64
47use Coro; 65use Coro;
66use Coro::Timer;
48use Event qw(loop unloop); # we are re-exporting this, cooool! 67use Event qw(loop unloop); # we are re-exporting this, cooool!
49 68
50use base 'Exporter'; 69use XSLoader;
51 70
71use base Exporter::;
72
52@EXPORT = qw(loop unloop sweep reschedule); 73our @EXPORT = qw(loop unloop sweep);
53 74
54BEGIN { 75BEGIN {
55 $VERSION = 0.45; 76 our $VERSION = 1.9;
56 77
57 local $^W = 0; # avoid redefine warning for Coro::ready 78 local $^W = 0; # avoid redefine warning for Coro::ready;
58 require XSLoader;
59 XSLoader::load Coro::Event, $VERSION; 79 XSLoader::load __PACKAGE__, $VERSION;
60} 80}
61 81
62=item $w = Coro::Event->flavour(args...) 82=item $w = Coro::Event->flavour (args...)
63 83
64Create and return a watcher of the given type. 84Create and return a watcher of the given type.
65 85
66Examples: 86Examples:
67 87
… …
74 94
75Return the next event of the event queue of the watcher. 95Return the next event of the event queue of the watcher.
76 96
77=cut 97=cut
78 98
79=item do_flavour(args...) 99=item do_flavour args...
80 100
81Create a watcher of the given type and immediately call it's next 101Create a watcher of the given type and immediately call it's next
82method. This is less efficient then calling the constructor once and the 102method. This is less efficient then calling the constructor once and the
83next method often, but it does save typing sometimes. 103next method often, but it does save typing sometimes.
84 104
… …
107 }; 127 };
108 *{ $flavour } = $coronew; 128 *{ $flavour } = $coronew;
109 *{"do_$flavour"} = sub { 129 *{"do_$flavour"} = sub {
110 unshift @_, Coro::Event::; 130 unshift @_, Coro::Event::;
111 my $e = (&$coronew)->next; 131 my $e = (&$coronew)->next;
112 $e->cancel; # $e = $e->w->cancel ($e == $e->w!) 132 $e->cancel; # $e === $e->w
113 $e; 133 $e;
114 }; 134 };
115} 135}
116 136
117# double calls to avoid stack-cloning ;() 137# double calls to avoid stack-cloning ;()
118# is about 10% slower, though. 138# is about 10% slower, though.
119sub next($) { 139sub next($) {
120 &Coro::schedule if &_next; $_[0]; 140 &Coro::schedule while &_next;
141
142 $_[0]
121} 143}
122 144
123sub Coro::Event::w { $_[0] } 145sub Coro::Event::w { $_[0] }
124sub Coro::Event::prio { $_[0]{Coro::Event}[3] } 146sub Coro::Event::prio { $_[0]{Coro::Event}[3] }
125sub Coro::Event::hits { $_[0]{Coro::Event}[4] } 147sub Coro::Event::hits { $_[0]{Coro::Event}[4] }
… …
137into the Event dispatcher. 159into the Event dispatcher.
138 160
139=cut 161=cut
140 162
141sub sweep { 163sub sweep {
142 Event::one_event(0); # for now 164 Event::one_event 0; # for now
143} 165}
144 166
145=item $result = loop([$timeout]) 167=item $result = loop([$timeout])
146 168
147This is the version of C<loop> you should use instead of C<Event::loop> 169This 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 170when using this module - it will ensure correct scheduling in the presence
149of events. 171of events.
150 172
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]) 173=item unloop([$result])
169 174
170Same as Event::unloop (provided here for your convinience only). 175Same as Event::unloop (provided here for your convinience only).
171 176
172=cut 177=cut
173 178
174$Coro::idle = new Coro sub { 179$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 180
1921; 1811;
193 182
183=back
184
194=head1 AUTHOR 185=head1 AUTHOR
195 186
196 Marc Lehmann <pcg@goof.com> 187 Marc Lehmann <schmorp@schmorp.de>
197 http://www.goof.com/pcg/marc/ 188 http://home.schmorp.de/
198 189
199=cut 190=cut
200 191

Diff Legend

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