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.27 by root, Thu Mar 3 17:20:31 2005 UTC vs.
Revision 1.42 by root, Fri Dec 1 02:24:46 2006 UTC

… …
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
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
53
37=over 4 54=over 4
38 55
39=cut 56=cut
40 57
41package Coro::Event; 58package Coro::Event;
42 59
43BEGIN { eval { require warnings } && warnings->unimport ("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 = 1.11; 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 79 XSLoader::load __PACKAGE__, $VERSION;
59 require DynaLoader;
60 push @ISA, 'DynaLoader';
61 bootstrap Coro::Event $VERSION;
62} 80}
63 81
64=item $w = Coro::Event->flavour(args...) 82=item $w = Coro::Event->flavour (args...)
65 83
66Create and return a watcher of the given type. 84Create and return a watcher of the given type.
67 85
68Examples: 86Examples:
69 87
… …
76 94
77Return the next event of the event queue of the watcher. 95Return the next event of the event queue of the watcher.
78 96
79=cut 97=cut
80 98
81=item do_flavour(args...) 99=item do_flavour args...
82 100
83Create 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
84method. This is less efficient then calling the constructor once and the 102method. This is less efficient then calling the constructor once and the
85next method often, but it does save typing sometimes. 103next method often, but it does save typing sometimes.
86 104
… …
117} 135}
118 136
119# double calls to avoid stack-cloning ;() 137# double calls to avoid stack-cloning ;()
120# is about 10% slower, though. 138# is about 10% slower, though.
121sub next($) { 139sub next($) {
122 &Coro::schedule if &_next; $_[0]; 140 &Coro::schedule while &_next;
141
142 $_[0]
123} 143}
124 144
125sub Coro::Event::w { $_[0] } 145sub Coro::Event::w { $_[0] }
126sub Coro::Event::prio { $_[0]{Coro::Event}[3] } 146sub Coro::Event::prio { $_[0]{Coro::Event}[3] }
127sub Coro::Event::hits { $_[0]{Coro::Event}[4] } 147sub Coro::Event::hits { $_[0]{Coro::Event}[4] }
… …
139into the Event dispatcher. 159into the Event dispatcher.
140 160
141=cut 161=cut
142 162
143sub sweep { 163sub sweep {
144 Event::one_event(0); # for now 164 Event::one_event 0; # for now
145} 165}
146 166
147=item $result = loop([$timeout]) 167=item $result = loop([$timeout])
148 168
149This 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>
150when using this module - it will ensure correct scheduling in the presence 170when using this module - it will ensure correct scheduling in the presence
151of events. 171of events.
152 172
153=begin comment
154
155Unlike loop's counterpart it is not an error when no watchers are active -
156loop silently returns in this case, as if unloop(undef) were called.
157
158=end comment
159
160=cut
161
162# no longer do something special - it's done internally now
163
164#sub loop(;$) {
165# #local $Coro::idle = $Coro::current;
166# #Coro::schedule; # become idle task, which is implicitly ready
167# &Event::loop;
168#}
169
170=item unloop([$result]) 173=item unloop([$result])
171 174
172Same as Event::unloop (provided here for your convinience only). 175Same as Event::unloop (provided here for your convinience only).
173 176
174=cut 177=cut
175 178
176$Coro::idle = new Coro sub { 179$Coro::idle = \&Event::one_event; # inefficient
177 while () {
178 Event::one_event; # inefficient
179 Coro::schedule;
180 }
181};
182
183# provide hooks for Coro::Timer
184
185package Coro::Timer;
186
187unless ($override) {
188 $override = 1;
189 *_new_timer = sub {
190 Event->timer(at => $_[0], cb => $_[1]);
191 };
192}
193 180
1941; 1811;
182
183=back
195 184
196=head1 AUTHOR 185=head1 AUTHOR
197 186
198 Marc Lehmann <schmorp@schmorp.de> 187 Marc Lehmann <schmorp@schmorp.de>
199 http://home.schmorp.de/ 188 http://home.schmorp.de/

Diff Legend

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