ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent/lib/AnyEvent.pm
(Generate patch)

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.81 by root, Fri Apr 25 13:05:17 2008 UTC vs.
Revision 1.85 by root, Fri Apr 25 13:51:32 2008 UTC

141=head2 I/O WATCHERS 141=head2 I/O WATCHERS
142 142
143You can create an I/O watcher by calling the C<< AnyEvent->io >> method 143You can create an I/O watcher by calling the C<< AnyEvent->io >> method
144with the following mandatory key-value pairs as arguments: 144with the following mandatory key-value pairs as arguments:
145 145
146C<fh> the Perl I<file handle> (I<not> file descriptor) to watch for 146C<fh> the Perl I<file handle> (I<not> file descriptor) to watch
147events. C<poll> must be a string that is either C<r> or C<w>, which 147for events. C<poll> must be a string that is either C<r> or C<w>,
148creates a watcher waiting for "r"eadable or "w"ritable events, 148which creates a watcher waiting for "r"eadable or "w"ritable events,
149respectively. C<cb> is the callback to invoke each time the file handle 149respectively. C<cb> is the callback to invoke each time the file handle
150becomes ready. 150becomes ready.
151 151
152As long as the I/O watcher exists it will keep the file descriptor or a 152Although the callback might get passed parameters, their value and
153copy of it alive/open. 153presence is undefined and you cannot rely on them. Portable AnyEvent
154callbacks cannot use arguments passed to I/O watcher callbacks.
154 155
156The I/O watcher might use the underlying file descriptor or a copy of it.
155It is not allowed to close a file handle as long as any watcher is active 157You must not close a file handle as long as any watcher is active on the
156on the underlying file descriptor. 158underlying file descriptor.
157 159
158Some event loops issue spurious readyness notifications, so you should 160Some event loops issue spurious readyness notifications, so you should
159always use non-blocking calls when reading/writing from/to your file 161always use non-blocking calls when reading/writing from/to your file
160handles. 162handles.
161 163
172 174
173You can create a time watcher by calling the C<< AnyEvent->timer >> 175You can create a time watcher by calling the C<< AnyEvent->timer >>
174method with the following mandatory arguments: 176method with the following mandatory arguments:
175 177
176C<after> specifies after how many seconds (fractional values are 178C<after> specifies after how many seconds (fractional values are
177supported) should the timer activate. C<cb> the callback to invoke in that 179supported) the callback should be invoked. C<cb> is the callback to invoke
178case. 180in that case.
181
182Although the callback might get passed parameters, their value and
183presence is undefined and you cannot rely on them. Portable AnyEvent
184callbacks cannot use arguments passed to time watcher callbacks.
179 185
180The timer callback will be invoked at most once: if you want a repeating 186The timer callback will be invoked at most once: if you want a repeating
181timer you have to create a new watcher (this is a limitation by both Tk 187timer you have to create a new watcher (this is a limitation by both Tk
182and Glib). 188and Glib).
183 189
228 234
229You can watch for signals using a signal watcher, C<signal> is the signal 235You can watch for signals using a signal watcher, C<signal> is the signal
230I<name> without any C<SIG> prefix, C<cb> is the Perl callback to 236I<name> without any C<SIG> prefix, C<cb> is the Perl callback to
231be invoked whenever a signal occurs. 237be invoked whenever a signal occurs.
232 238
239Although the callback might get passed parameters, their value and
240presence is undefined and you cannot rely on them. Portable AnyEvent
241callbacks cannot use arguments passed to signal watcher callbacks.
242
233Multiple signal occurances can be clumped together into one callback 243Multiple signal occurances can be clumped together into one callback
234invocation, and callback invocation will be synchronous. synchronous means 244invocation, and callback invocation will be synchronous. synchronous means
235that it might take a while until the signal gets handled by the process, 245that it might take a while until the signal gets handled by the process,
236but it is guarenteed not to interrupt any other callbacks. 246but it is guarenteed not to interrupt any other callbacks.
237 247
251 261
252The child process is specified by the C<pid> argument (if set to C<0>, it 262The child process is specified by the C<pid> argument (if set to C<0>, it
253watches for any child process exit). The watcher will trigger as often 263watches for any child process exit). The watcher will trigger as often
254as status change for the child are received. This works by installing a 264as status change for the child are received. This works by installing a
255signal handler for C<SIGCHLD>. The callback will be called with the pid 265signal handler for C<SIGCHLD>. The callback will be called with the pid
256and exit status (as returned by waitpid). 266and exit status (as returned by waitpid), so unlike other watcher types,
267you I<can> rely on child watcher callback arguments.
257 268
258Example: wait for pid 1333 269There is a slight catch to child watchers, however: you usually start them
270I<after> the child process was created, and this means the process could
271have exited already (and no SIGCHLD will be sent anymore).
272
273Not all event models handle this correctly (POE doesn't), but even for
274event models that I<do> handle this correctly, they usually need to be
275loaded before the process exits (i.e. before you fork in the first place).
276
277This means you cannot create a child watcher as the very first thing in an
278AnyEvent program, you I<have> to create at least one watcher before you
279C<fork> the child (alternatively, you can call C<AnyEvent::detect>).
280
281Example: fork a process and wait for it
282
283 my $done = AnyEvent->condvar;
284
285 AnyEvent::detect; # force event module to be initialised
286
287 my $pid = fork or exit 5;
259 288
260 my $w = AnyEvent->child ( 289 my $w = AnyEvent->child (
261 pid => 1333, 290 pid => $pid,
262 cb => sub { 291 cb => sub {
263 my ($pid, $status) = @_; 292 my ($pid, $status) = @_;
264 warn "pid $pid exited with status $status"; 293 warn "pid $pid exited with status $status";
294 $done->broadcast;
265 }, 295 },
266 ); 296 );
297
298 # do something else, then wait for process exit
299 $done->wait;
267 300
268=head2 CONDITION VARIABLES 301=head2 CONDITION VARIABLES
269 302
270Condition variables can be created by calling the C<< AnyEvent->condvar >> 303Condition variables can be created by calling the C<< AnyEvent->condvar >>
271method without any arguments. 304method without any arguments.
906 939
907=head2 Results 940=head2 Results
908 941
909 name watchers bytes create invoke destroy comment 942 name watchers bytes create invoke destroy comment
910 EV/EV 400000 244 0.56 0.46 0.31 EV native interface 943 EV/EV 400000 244 0.56 0.46 0.31 EV native interface
911 EV/Any 100000 610 3.52 0.91 0.75 EV + AnyEvent watchers 944 EV/Any 100000 244 2.50 0.46 0.29 EV + AnyEvent watchers
912 CoroEV/Any 100000 610 3.49 0.92 0.75 coroutines + Coro::Signal 945 CoroEV/Any 100000 244 2.49 0.44 0.29 coroutines + Coro::Signal
913 Perl/Any 100000 513 4.91 0.92 1.15 pure perl implementation 946 Perl/Any 100000 513 4.92 0.87 1.12 pure perl implementation
914 Event/Event 16000 523 28.05 21.38 0.86 Event native interface 947 Event/Event 16000 516 31.88 31.30 0.85 Event native interface
915 Event/Any 16000 943 34.43 20.48 1.39 Event + AnyEvent watchers 948 Event/Any 16000 936 39.17 33.63 1.43 Event + AnyEvent watchers
916 Glib/Any 16000 1357 96.99 12.55 55.51 quadratic behaviour 949 Glib/Any 16000 1357 98.22 12.41 54.00 quadratic behaviour
917 Tk/Any 2000 1855 27.01 66.61 14.03 SEGV with >> 2000 watchers 950 Tk/Any 2000 1860 26.97 67.98 14.00 SEGV with >> 2000 watchers
918 POE/Event 2000 6644 108.15 768.19 14.33 via POE::Loop::Event 951 POE/Event 2000 6644 108.64 736.02 14.73 via POE::Loop::Event
919 POE/Select 2000 6343 94.69 807.65 562.69 via POE::Loop::Select 952 POE/Select 2000 6343 94.13 809.12 565.96 via POE::Loop::Select
920 953
921=head2 Discussion 954=head2 Discussion
922 955
923The benchmark does I<not> measure scalability of the event loop very 956The benchmark does I<not> measure scalability of the event loop very
924well. For example, a select-based event loop (such as the pure perl one) 957well. For example, a select-based event loop (such as the pure perl one)
926file descriptors grows high. In this benchmark, all events become ready at 959file descriptors grows high. In this benchmark, all events become ready at
927the same time, so select/poll-based implementations get an unnatural speed 960the same time, so select/poll-based implementations get an unnatural speed
928boost. 961boost.
929 962
930C<EV> is the sole leader regarding speed and memory use, which are both 963C<EV> is the sole leader regarding speed and memory use, which are both
931maximal/minimal, respectively. Even when going through AnyEvent, there are 964maximal/minimal, respectively. Even when going through AnyEvent, it uses
932only two event loops that use slightly less memory (the C<Event> module 965far less memory than any other event loop and is still faster than Event
933natively and the pure perl backend), and no faster event models, not even 966natively.
934C<Event> natively.
935 967
936The pure perl implementation is hit in a few sweet spots (both the 968The pure perl implementation is hit in a few sweet spots (both the
937zero timeout and the use of a single fd hit optimisations in the perl 969zero timeout and the use of a single fd hit optimisations in the perl
938interpreter and the backend itself, and all watchers become ready at the 970interpreter and the backend itself, and all watchers become ready at the
939same time). Nevertheless this shows that it adds very little overhead in 971same time). Nevertheless this shows that it adds very little overhead in

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines