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.7 by root, Tue Oct 9 00:50:32 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
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;
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 local $^W = 0; # avoid redefine warning for Coro::ready 65 local $^W = 0; # avoid redefine warning for Coro::ready;
58 require XSLoader;
59 XSLoader::load Coro::Event, $VERSION; 66 XSLoader::load __PACKAGE__, $VERSION;
60} 67}
61 68
62=item $w = Coro::Event->flavour(args...) 69=item $w = Coro::Event->flavour(args...)
63 70
64Create and return a watcher of the given type. 71Create and return a watcher of the given type.
… …
92 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour"); 99 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour");
93 my $coronew = sub { 100 my $coronew = sub {
94 # how does one do method-call-by-name? 101 # how does one do method-call-by-name?
95 # my $w = $class->SUPER::$flavour(@_); 102 # my $w = $class->SUPER::$flavour(@_);
96 103
97 $_[0] eq Coro::Event:: 104 shift eq Coro::Event::
98 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";
99 106
100 my $q = []; # [$coro, $event]
101 my $w = $new->( 107 my $w = $new->($class,
102 desc => $flavour, 108 desc => $flavour,
103 @_, 109 @_,
104 parked => 1, 110 parked => 1,
105 ); 111 );
106 _install_std_cb($w, $type); 112 _install_std_cb($w, $type);
… …
108 }; 114 };
109 *{ $flavour } = $coronew; 115 *{ $flavour } = $coronew;
110 *{"do_$flavour"} = sub { 116 *{"do_$flavour"} = sub {
111 unshift @_, Coro::Event::; 117 unshift @_, Coro::Event::;
112 my $e = (&$coronew)->next; 118 my $e = (&$coronew)->next;
113 $e->cancel; # $e = $e->w 119 $e->cancel; # $e === $e->w
114 $e; 120 $e;
115 }; 121 };
116} 122}
117 123
118# double calls to avoid stack-cloning ;() 124# double calls to avoid stack-cloning ;()
… …
156 162
157=end comment 163=end comment
158 164
159=cut 165=cut
160 166
167# no longer do something special - it's done internally now
168
161sub loop(;$) { 169#sub loop(;$) {
162 local $Coro::idle = $Coro::current; 170# #local $Coro::idle = $Coro::current;
163 Coro::schedule; # become idle task, which is implicitly ready 171# #Coro::schedule; # become idle task, which is implicitly ready
164 &Event::loop; 172# &Event::loop;
165} 173#}
166 174
167=item unloop([$result]) 175=item unloop([$result])
168 176
169Same as Event::unloop (provided here for your convinience only). 177Same as Event::unloop (provided here for your convinience only).
170 178
… …
175 Event::one_event; # inefficient 183 Event::one_event; # inefficient
176 Coro::schedule; 184 Coro::schedule;
177 } 185 }
178}; 186};
179 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
1801; 1991;
181 200
201=back
202
182=head1 AUTHOR 203=head1 AUTHOR
183 204
184 Marc Lehmann <pcg@goof.com> 205 Marc Lehmann <schmorp@schmorp.de>
185 http://www.goof.com/pcg/marc/ 206 http://home.schmorp.de/
186 207
187=cut 208=cut
188 209

Diff Legend

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