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.3 by root, Fri Aug 17 03:33:00 2001 UTC vs.
Revision 1.40 by root, Fri Nov 24 15:34:33 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> ";
17 my $ev = $w->next; my $data = <STDIN>; 17 my $ev = $w->next; my $data = <STDIN>;
18 } 18 }
19 } 19 }
20 20
21 &loop; 21 loop;
22 22
23=head1 DESCRIPTION 23=head1 DESCRIPTION
24 24
25This module enables you to create programs using the powerful Event model 25This module enables you to create programs using the powerful Event model
26(and module), while retaining the linear style known from simple or 26(and module), while retaining the linear style known from simple or
… …
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.
36 41
37=over 4 42=over 4
38 43
39=cut 44=cut
40 45
41package Coro::Event; 46package Coro::Event;
42 47
48BEGIN { eval { require warnings } && warnings->unimport ("uninitialized") }
49
50use Carp;
43no warnings; 51no warnings;
44 52
45use Carp; 53use Coro;
54use Coro::Timer;
55use Event qw(loop unloop); # we are re-exporting this, cooool!
46 56
47use Coro; 57use XSLoader;
48use Event qw(unloop); # we are re-exporting this, cooool!
49 58
50use base 'Exporter'; 59use base Exporter::;
51 60
52@EXPORT = qw(loop unloop sweep); 61our @EXPORT = qw(loop unloop sweep reschedule);
53 62
54BEGIN { 63BEGIN {
55 $VERSION = 0.45; 64 our $VERSION = 1.9;
56 65
57 require XSLoader; 66 local $^W = 0; # avoid redefine warning for Coro::ready;
58 XSLoader::load Coro::Event, $VERSION; 67 XSLoader::load __PACKAGE__, $VERSION;
59} 68}
60 69
61=item $w = Coro::Event->flavour(args...) 70=item $w = Coro::Event->flavour(args...)
62 71
63Create and return a watcher of the given type. 72Create and return a watcher of the given type.
… …
91 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour"); 100 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour");
92 my $coronew = sub { 101 my $coronew = sub {
93 # how does one do method-call-by-name? 102 # how does one do method-call-by-name?
94 # my $w = $class->SUPER::$flavour(@_); 103 # my $w = $class->SUPER::$flavour(@_);
95 104
96 $_[0] eq Coro::Event:: 105 shift eq Coro::Event::
97 or croak "event constructor \"Coro::Event->$flavour\" must be called as a static method"; 106 or croak "event constructor \"Coro::Event->$flavour\" must be called as a static method";
98 107
99 my $q = []; # [$coro, $event]
100 my $w = $new->( 108 my $w = $new->($class,
101 desc => $flavour, 109 desc => $flavour,
102 @_, 110 @_,
103 parked => 1, 111 parked => 1,
104 ); 112 );
105 _install_std_cb($w, $type); 113 _install_std_cb($w, $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->w->cancel; 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 if &_next; $_[0];
121} 129}
122 130
131sub Coro::Event::w { $_[0] }
123sub Coro::Event::w { $_[0]{Coro::Event}[2] } 132sub Coro::Event::prio { $_[0]{Coro::Event}[3] }
133sub Coro::Event::hits { $_[0]{Coro::Event}[4] }
124sub Coro::Event::got { $_[0]{Coro::Event}[3] } 134sub Coro::Event::got { $_[0]{Coro::Event}[5] }
125sub Coro::Event::prio { croak "prio not supported yet, please mail to pcg\@goof.com" }
126sub Coro::Event::hits { croak "prio not supported yet, please mail to pcg\@goof.com" }
127 135
128=item sweep 136=item sweep
129 137
130Similar to Event::one_event and Event::sweep: The idle task is called once 138Similar to Event::one_event and Event::sweep: The idle task is called once
131(this has the effect of jumping back into the Event loop once to serve new 139(this has the effect of jumping back into the Event loop once to serve new
… …
137into the Event dispatcher. 145into the Event dispatcher.
138 146
139=cut 147=cut
140 148
141sub sweep { 149sub sweep {
142 one_event(0); # for now 150 Event::one_event(0); # for now
143} 151}
144 152
145=item $result = loop([$timeout]) 153=item $result = loop([$timeout])
146 154
147This is the version of C<loop> you should use instead of C<Event::loop> 155This 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 156when using this module - it will ensure correct scheduling in the presence
149of events. 157of events.
150 158
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
160sub loop(;$) {
161 local $Coro::idle = $Coro::current;
162 Coro::schedule; # become idle task, which is implicitly ready
163 &Event::loop;
164}
165
166=item unloop([$result]) 159=item unloop([$result])
167 160
168Same as Event::unloop (provided here for your convinience only). 161Same as Event::unloop (provided here for your convinience only).
169 162
170=cut 163=cut
171 164
172$Coro::idle = new Coro sub { 165$Coro::idle = \&Event::one_event; # inefficient
173 while () {
174 Event::one_event; # inefficient
175 Coro::schedule;
176 }
177};
178 166
1791; 1671;
180 168
169=back
170
181=head1 AUTHOR 171=head1 AUTHOR
182 172
183 Marc Lehmann <pcg@goof.com> 173 Marc Lehmann <schmorp@schmorp.de>
184 http://www.goof.com/pcg/marc/ 174 http://home.schmorp.de/
185 175
186=cut 176=cut
187 177

Diff Legend

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