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.5 by root, Sat Aug 18 02:58:38 2001 UTC vs.
Revision 1.37 by root, Mon Nov 20 19:56:04 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;
46
47use Coro; 53use Coro;
48use Event qw(unloop); # we are re-exporting this, cooool! 54use Event qw(loop unloop); # we are re-exporting this, cooool!
49 55
56use XSLoader;
57
50use base 'Exporter'; 58use base Exporter::;
51 59
52@EXPORT = qw(loop unloop sweep reschedule); 60our @EXPORT = qw(loop unloop sweep reschedule);
53 61
54BEGIN { 62BEGIN {
55 $VERSION = 0.45; 63 our $VERSION = 1.9;
56 64
57 require XSLoader; 65 local $^W = 0; # avoid redefine warning for Coro::ready;
58 XSLoader::load Coro::Event, $VERSION; 66 XSLoader::load __PACKAGE__, $VERSION;
59} 67}
60 68
61=item $w = Coro::Event->flavour(args...) 69=item $w = Coro::Event->flavour(args...)
62 70
63Create and return a watcher of the given type. 71Create and return a watcher of the given type.
… …
91 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour"); 99 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour");
92 my $coronew = sub { 100 my $coronew = sub {
93 # how does one do method-call-by-name? 101 # how does one do method-call-by-name?
94 # my $w = $class->SUPER::$flavour(@_); 102 # my $w = $class->SUPER::$flavour(@_);
95 103
96 $_[0] eq Coro::Event:: 104 shift eq Coro::Event::
97 or croak "event constructor \"Coro::Event->$flavour\" must be called as a static method"; 105 or croak "event constructor \"Coro::Event->$flavour\" must be called as a static method";
98 106
99 my $q = []; # [$coro, $event]
100 my $w = $new->( 107 my $w = $new->($class,
101 desc => $flavour, 108 desc => $flavour,
102 @_, 109 @_,
103 parked => 1, 110 parked => 1,
104 ); 111 );
105 _install_std_cb($w, $type); 112 _install_std_cb($w, $type);
… …
107 }; 114 };
108 *{ $flavour } = $coronew; 115 *{ $flavour } = $coronew;
109 *{"do_$flavour"} = sub { 116 *{"do_$flavour"} = sub {
110 unshift @_, Coro::Event::; 117 unshift @_, Coro::Event::;
111 my $e = (&$coronew)->next; 118 my $e = (&$coronew)->next;
112 $e->cancel; # $e = $e->w 119 $e->cancel; # $e === $e->w
113 $e; 120 $e;
114 }; 121 };
115} 122}
116 123
117# double calls to avoid stack-cloning ;() 124# double calls to avoid stack-cloning ;()
… …
137into the Event dispatcher. 144into the Event dispatcher.
138 145
139=cut 146=cut
140 147
141sub sweep { 148sub sweep {
142 one_event(0); # for now 149 Event::one_event(0); # for now
143} 150}
144 151
145=item $result = loop([$timeout]) 152=item $result = loop([$timeout])
146 153
147This is the version of C<loop> you should use instead of C<Event::loop> 154This is the version of C<loop> you should use instead of C<Event::loop>
… …
155 162
156=end comment 163=end comment
157 164
158=cut 165=cut
159 166
167# no longer do something special - it's done internally now
168
160sub loop(;$) { 169#sub loop(;$) {
161 local $Coro::idle = $Coro::current; 170# #local $Coro::idle = $Coro::current;
162 Coro::schedule; # become idle task, which is implicitly ready 171# #Coro::schedule; # become idle task, which is implicitly ready
163 &Event::loop; 172# &Event::loop;
164} 173#}
165 174
166=item unloop([$result]) 175=item unloop([$result])
167 176
168Same as Event::unloop (provided here for your convinience only). 177Same as Event::unloop (provided here for your convinience only).
169 178
… …
174 Event::one_event; # inefficient 183 Event::one_event; # inefficient
175 Coro::schedule; 184 Coro::schedule;
176 } 185 }
177}; 186};
178 187
188# provide hooks for Coro::Timer
189
190package Coro::Timer;
191
192unless ($override) {
193 $override = 1;
194 *_new_timer = sub {
195 Event->timer(at => $_[0], cb => $_[1]);
196 };
197}
198
1791; 1991;
180 200
201=back
202
181=head1 AUTHOR 203=head1 AUTHOR
182 204
183 Marc Lehmann <pcg@goof.com> 205 Marc Lehmann <schmorp@schmorp.de>
184 http://www.goof.com/pcg/marc/ 206 http://home.schmorp.de/
185 207
186=cut 208=cut
187 209

Diff Legend

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