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

Comparing AnyEvent/README (file contents):
Revision 1.50 by root, Sat Aug 1 09:14:54 2009 UTC vs.
Revision 1.56 by root, Thu Nov 19 01:55:57 2009 UTC

353 then this "current" time will differ substantially from the real 353 then this "current" time will differ substantially from the real
354 time, which might affect timers and time-outs. 354 time, which might affect timers and time-outs.
355 355
356 When this is the case, you can call this method, which will update 356 When this is the case, you can call this method, which will update
357 the event loop's idea of "current time". 357 the event loop's idea of "current time".
358
359 A typical example would be a script in a web server (e.g.
360 "mod_perl") - when mod_perl executes the script, then the event loop
361 will have the wrong idea about the "current time" (being potentially
362 far in the past, when the script ran the last time). In that case
363 you should arrange a call to "AnyEvent->now_update" each time the
364 web server process wakes up again (e.g. at the start of your script,
365 or in a handler).
358 366
359 Note that updating the time *might* cause some events to be handled. 367 Note that updating the time *might* cause some events to be handled.
360 368
361 SIGNAL WATCHERS 369 SIGNAL WATCHERS
362 $w = AnyEvent->signal (signal => <uppercase_signal_name>, cb => <callback>); 370 $w = AnyEvent->signal (signal => <uppercase_signal_name>, cb => <callback>);
576 after => 1, 584 after => 1,
577 cb => sub { $result_ready->send }, 585 cb => sub { $result_ready->send },
578 ); 586 );
579 587
580 # this "blocks" (while handling events) till the callback 588 # this "blocks" (while handling events) till the callback
581 # calls -<send 589 # calls ->send
582 $result_ready->recv; 590 $result_ready->recv;
583 591
584 Example: wait for a timer, but take advantage of the fact that condition 592 Example: wait for a timer, but take advantage of the fact that condition
585 variables are also callable directly. 593 variables are also callable directly.
586 594
643 into one. For example, a function that pings many hosts in parallel 651 into one. For example, a function that pings many hosts in parallel
644 might want to use a condition variable for the whole process. 652 might want to use a condition variable for the whole process.
645 653
646 Every call to "->begin" will increment a counter, and every call to 654 Every call to "->begin" will increment a counter, and every call to
647 "->end" will decrement it. If the counter reaches 0 in "->end", the 655 "->end" will decrement it. If the counter reaches 0 in "->end", the
648 (last) callback passed to "begin" will be executed. That callback is 656 (last) callback passed to "begin" will be executed, passing the
649 *supposed* to call "->send", but that is not required. If no 657 condvar as first argument. That callback is *supposed* to call
658 "->send", but that is not required. If no group callback was set,
650 callback was set, "send" will be called without any arguments. 659 "send" will be called without any arguments.
651 660
652 You can think of "$cv->send" giving you an OR condition (one call 661 You can think of "$cv->send" giving you an OR condition (one call
653 sends), while "$cv->begin" and "$cv->end" giving you an AND 662 sends), while "$cv->begin" and "$cv->end" giving you an AND
654 condition (all "begin" calls must be "end"'ed before the condvar 663 condition (all "begin" calls must be "end"'ed before the condvar
655 sends). 664 sends).
683 that are begung can potentially be zero: 692 that are begung can potentially be zero:
684 693
685 my $cv = AnyEvent->condvar; 694 my $cv = AnyEvent->condvar;
686 695
687 my %result; 696 my %result;
688 $cv->begin (sub { $cv->send (\%result) }); 697 $cv->begin (sub { shift->send (\%result) });
689 698
690 for my $host (@list_of_hosts) { 699 for my $host (@list_of_hosts) {
691 $cv->begin; 700 $cv->begin;
692 ping_host_then_call_callback $host, sub { 701 ping_host_then_call_callback $host, sub {
693 $result{$host} = ...; 702 $result{$host} = ...;
771SUPPORTED EVENT LOOPS/BACKENDS 780SUPPORTED EVENT LOOPS/BACKENDS
772 The available backend classes are (every class has its own manpage): 781 The available backend classes are (every class has its own manpage):
773 782
774 Backends that are autoprobed when no other event loop can be found. 783 Backends that are autoprobed when no other event loop can be found.
775 EV is the preferred backend when no other event loop seems to be in 784 EV is the preferred backend when no other event loop seems to be in
776 use. If EV is not installed, then AnyEvent will try Event, and, 785 use. If EV is not installed, then AnyEvent will fall back to its own
777 failing that, will fall back to its own pure-perl implementation, 786 pure-perl implementation, which is available everywhere as it comes
778 which is available everywhere as it comes with AnyEvent itself. 787 with AnyEvent itself.
779 788
780 AnyEvent::Impl::EV based on EV (interface to libev, best choice). 789 AnyEvent::Impl::EV based on EV (interface to libev, best choice).
781 AnyEvent::Impl::Event based on Event, very stable, few glitches.
782 AnyEvent::Impl::Perl pure-perl implementation, fast and portable. 790 AnyEvent::Impl::Perl pure-perl implementation, fast and portable.
783 791
784 Backends that are transparently being picked up when they are used. 792 Backends that are transparently being picked up when they are used.
785 These will be used when they are currently loaded when the first 793 These will be used when they are currently loaded when the first
786 watcher is created, in which case it is assumed that the application 794 watcher is created, in which case it is assumed that the application
787 is using them. This means that AnyEvent will automatically pick the 795 is using them. This means that AnyEvent will automatically pick the
788 right backend when the main program loads an event module before 796 right backend when the main program loads an event module before
789 anything starts to create watchers. Nothing special needs to be done 797 anything starts to create watchers. Nothing special needs to be done
790 by the main program. 798 by the main program.
791 799
800 AnyEvent::Impl::Event based on Event, very stable, few glitches.
792 AnyEvent::Impl::Glib based on Glib, slow but very stable. 801 AnyEvent::Impl::Glib based on Glib, slow but very stable.
793 AnyEvent::Impl::Tk based on Tk, very broken. 802 AnyEvent::Impl::Tk based on Tk, very broken.
794 AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse. 803 AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse.
795 AnyEvent::Impl::POE based on POE, very slow, some limitations. 804 AnyEvent::Impl::POE based on POE, very slow, some limitations.
796 AnyEvent::Impl::Irssi used when running within irssi. 805 AnyEvent::Impl::Irssi used when running within irssi.
1032 Event::ExecFlow 1041 Event::ExecFlow
1033 High level API for event-based execution flow control. 1042 High level API for event-based execution flow control.
1034 1043
1035 Coro 1044 Coro
1036 Has special support for AnyEvent via Coro::AnyEvent. 1045 Has special support for AnyEvent via Coro::AnyEvent.
1046
1047SIMPLIFIED AE API
1048 Starting with version 5.0, AnyEvent officially supports a second, much
1049 simpler, API that is designed to reduce the calling, typing and memory
1050 overhead.
1051
1052 See the AE manpage for details.
1037 1053
1038ERROR AND EXCEPTION HANDLING 1054ERROR AND EXCEPTION HANDLING
1039 In general, AnyEvent does not do any error handling - it relies on the 1055 In general, AnyEvent does not do any error handling - it relies on the
1040 caller to do that if required. The AnyEvent::Strict module (see also the 1056 caller to do that if required. The AnyEvent::Strict module (see also the
1041 "PERL_ANYEVENT_STRICT" environment variable, below) provides strict 1057 "PERL_ANYEVENT_STRICT" environment variable, below) provides strict
1220 warn "read: $input\n"; # output what has been read 1236 warn "read: $input\n"; # output what has been read
1221 $cv->send if $input =~ /^q/i; # quit program if /^q/i 1237 $cv->send if $input =~ /^q/i; # quit program if /^q/i
1222 }, 1238 },
1223 ); 1239 );
1224 1240
1225 my $time_watcher; # can only be used once
1226
1227 sub new_timer {
1228 $timer = AnyEvent->timer (after => 1, cb => sub { 1241 my $time_watcher = AnyEvent->timer (after => 1, interval => 1, cb => sub {
1229 warn "timeout\n"; # print 'timeout' about every second 1242 warn "timeout\n"; # print 'timeout' at most every second
1230 &new_timer; # and restart the time
1231 });
1232 } 1243 });
1233
1234 new_timer; # create first timer
1235 1244
1236 $cv->recv; # wait until user enters /^q/i 1245 $cv->recv; # wait until user enters /^q/i
1237 1246
1238REAL-WORLD EXAMPLE 1247REAL-WORLD EXAMPLE
1239 Consider the Net::FCP module. It features (among others) the following 1248 Consider the Net::FCP module. It features (among others) the following
1366 through AnyEvent. The benchmark creates a lot of timers (with a zero 1375 through AnyEvent. The benchmark creates a lot of timers (with a zero
1367 timeout) and I/O watchers (watching STDOUT, a pty, to become writable, 1376 timeout) and I/O watchers (watching STDOUT, a pty, to become writable,
1368 which it is), lets them fire exactly once and destroys them again. 1377 which it is), lets them fire exactly once and destroys them again.
1369 1378
1370 Source code for this benchmark is found as eg/bench in the AnyEvent 1379 Source code for this benchmark is found as eg/bench in the AnyEvent
1371 distribution. 1380 distribution. It uses the AE interface, which makes a real difference
1381 for the EV and Perl backends only.
1372 1382
1373 Explanation of the columns 1383 Explanation of the columns
1374 *watcher* is the number of event watchers created/destroyed. Since 1384 *watcher* is the number of event watchers created/destroyed. Since
1375 different event models feature vastly different performances, each event 1385 different event models feature vastly different performances, each event
1376 loop was given a number of watchers so that overall runtime is 1386 loop was given a number of watchers so that overall runtime is
1395 *destroy* is the time, in microseconds, that it takes to destroy a 1405 *destroy* is the time, in microseconds, that it takes to destroy a
1396 single watcher. 1406 single watcher.
1397 1407
1398 Results 1408 Results
1399 name watchers bytes create invoke destroy comment 1409 name watchers bytes create invoke destroy comment
1400 EV/EV 400000 224 0.47 0.35 0.27 EV native interface 1410 EV/EV 100000 223 0.47 0.43 0.27 EV native interface
1401 EV/Any 100000 224 2.88 0.34 0.27 EV + AnyEvent watchers 1411 EV/Any 100000 223 0.48 0.42 0.26 EV + AnyEvent watchers
1402 CoroEV/Any 100000 224 2.85 0.35 0.28 coroutines + Coro::Signal 1412 Coro::EV/Any 100000 223 0.47 0.42 0.26 coroutines + Coro::Signal
1403 Perl/Any 100000 452 4.13 0.73 0.95 pure perl implementation 1413 Perl/Any 100000 431 2.70 0.74 0.92 pure perl implementation
1404 Event/Event 16000 517 32.20 31.80 0.81 Event native interface 1414 Event/Event 16000 516 31.16 31.84 0.82 Event native interface
1405 Event/Any 16000 590 35.85 31.55 1.06 Event + AnyEvent watchers 1415 Event/Any 16000 1203 42.61 34.79 1.80 Event + AnyEvent watchers
1406 IOAsync/Any 16000 989 38.10 32.77 11.13 via IO::Async::Loop::IO_Poll 1416 IOAsync/Any 16000 1911 41.92 27.45 16.81 via IO::Async::Loop::IO_Poll
1407 IOAsync/Any 16000 990 37.59 29.50 10.61 via IO::Async::Loop::Epoll 1417 IOAsync/Any 16000 1726 40.69 26.37 15.25 via IO::Async::Loop::Epoll
1408 Glib/Any 16000 1357 102.33 12.31 51.00 quadratic behaviour 1418 Glib/Any 16000 1118 89.00 12.57 51.17 quadratic behaviour
1409 Tk/Any 2000 1860 27.20 66.31 14.00 SEGV with >> 2000 watchers 1419 Tk/Any 2000 1346 20.96 10.75 8.00 SEGV with >> 2000 watchers
1410 POE/Event 2000 6328 109.99 751.67 14.02 via POE::Loop::Event 1420 POE/Any 2000 6951 108.97 795.32 14.24 via POE::Loop::Event
1411 POE/Select 2000 6027 94.54 809.13 579.80 via POE::Loop::Select 1421 POE/Any 2000 6648 94.79 774.40 575.51 via POE::Loop::Select
1412 1422
1413 Discussion 1423 Discussion
1414 The benchmark does *not* measure scalability of the event loop very 1424 The benchmark does *not* measure scalability of the event loop very
1415 well. For example, a select-based event loop (such as the pure perl one) 1425 well. For example, a select-based event loop (such as the pure perl one)
1416 can never compete with an event loop that uses epoll when the number of 1426 can never compete with an event loop that uses epoll when the number of
1427 benchmark machine, handling an event takes roughly 1600 CPU cycles with 1437 benchmark machine, handling an event takes roughly 1600 CPU cycles with
1428 EV, 3100 CPU cycles with AnyEvent's pure perl loop and almost 3000000 1438 EV, 3100 CPU cycles with AnyEvent's pure perl loop and almost 3000000
1429 CPU cycles with POE. 1439 CPU cycles with POE.
1430 1440
1431 "EV" is the sole leader regarding speed and memory use, which are both 1441 "EV" is the sole leader regarding speed and memory use, which are both
1432 maximal/minimal, respectively. Even when going through AnyEvent, it uses 1442 maximal/minimal, respectively. When using the AE API there is zero
1443 overhead (when going through the AnyEvent API create is about 5-6 times
1444 slower, with other times being equal, so still uses far less memory than
1433 far less memory than any other event loop and is still faster than Event 1445 any other event loop and is still faster than Event natively).
1434 natively.
1435 1446
1436 The pure perl implementation is hit in a few sweet spots (both the 1447 The pure perl implementation is hit in a few sweet spots (both the
1437 constant timeout and the use of a single fd hit optimisations in the 1448 constant timeout and the use of a single fd hit optimisations in the
1438 perl interpreter and the backend itself). Nevertheless this shows that 1449 perl interpreter and the backend itself). Nevertheless this shows that
1439 it adds very little overhead in itself. Like any select-based backend 1450 it adds very little overhead in itself. Like any select-based backend
1509 In this benchmark, we use 10000 socket pairs (20000 sockets), of which 1520 In this benchmark, we use 10000 socket pairs (20000 sockets), of which
1510 100 (1%) are active. This mirrors the activity of large servers with 1521 100 (1%) are active. This mirrors the activity of large servers with
1511 many connections, most of which are idle at any one point in time. 1522 many connections, most of which are idle at any one point in time.
1512 1523
1513 Source code for this benchmark is found as eg/bench2 in the AnyEvent 1524 Source code for this benchmark is found as eg/bench2 in the AnyEvent
1514 distribution. 1525 distribution. It uses the AE interface, which makes a real difference
1526 for the EV and Perl backends only.
1515 1527
1516 Explanation of the columns 1528 Explanation of the columns
1517 *sockets* is the number of sockets, and twice the number of "servers" 1529 *sockets* is the number of sockets, and twice the number of "servers"
1518 (as each server has a read and write socket end). 1530 (as each server has a read and write socket end).
1519 1531
1525 forwarding it to another server. This includes deleting the old timeout 1537 forwarding it to another server. This includes deleting the old timeout
1526 and creating a new one that moves the timeout into the future. 1538 and creating a new one that moves the timeout into the future.
1527 1539
1528 Results 1540 Results
1529 name sockets create request 1541 name sockets create request
1530 EV 20000 69.01 11.16 1542 EV 20000 62.66 7.99
1531 Perl 20000 73.32 35.87 1543 Perl 20000 68.32 32.64
1532 IOAsync 20000 157.00 98.14 epoll 1544 IOAsync 20000 174.06 101.15 epoll
1533 IOAsync 20000 159.31 616.06 poll 1545 IOAsync 20000 174.67 610.84 poll
1534 Event 20000 212.62 257.32 1546 Event 20000 202.69 242.91
1535 Glib 20000 651.16 1896.30 1547 Glib 20000 557.01 1689.52
1536 POE 20000 349.67 12317.24 uses POE::Loop::Event 1548 POE 20000 341.54 12086.32 uses POE::Loop::Event
1537 1549
1538 Discussion 1550 Discussion
1539 This benchmark *does* measure scalability and overall performance of the 1551 This benchmark *does* measure scalability and overall performance of the
1540 particular event loop. 1552 particular event loop.
1541 1553
1654 As you can see, the AnyEvent + EV combination even beats the 1666 As you can see, the AnyEvent + EV combination even beats the
1655 hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl 1667 hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl
1656 backend easily beats IO::Lambda and POE. 1668 backend easily beats IO::Lambda and POE.
1657 1669
1658 And even the 100% non-blocking version written using the high-level (and 1670 And even the 100% non-blocking version written using the high-level (and
1659 slow :) AnyEvent::Handle abstraction beats both POE and IO::Lambda by a 1671 slow :) AnyEvent::Handle abstraction beats both POE and IO::Lambda
1660 large margin, even though it does all of DNS, tcp-connect and socket I/O 1672 higher level ("unoptimised") abstractions by a large margin, even though
1661 in a non-blocking way. 1673 it does all of DNS, tcp-connect and socket I/O in a non-blocking way.
1662 1674
1663 The two AnyEvent benchmarks programs can be found as eg/ae0.pl and 1675 The two AnyEvent benchmarks programs can be found as eg/ae0.pl and
1664 eg/ae2.pl in the AnyEvent distribution, the remaining benchmarks are 1676 eg/ae2.pl in the AnyEvent distribution, the remaining benchmarks are
1665 part of the IO::lambda distribution and were used without any changes. 1677 part of the IO::Lambda distribution and were used without any changes.
1666 1678
1667SIGNALS 1679SIGNALS
1668 AnyEvent currently installs handlers for these signals: 1680 AnyEvent currently installs handlers for these signals:
1669 1681
1670 SIGCHLD 1682 SIGCHLD
1738 "AnyEvent::Util::guard". This speeds up guards considerably (and 1750 "AnyEvent::Util::guard". This speeds up guards considerably (and
1739 uses a lot less memory), but otherwise doesn't affect guard 1751 uses a lot less memory), but otherwise doesn't affect guard
1740 operation much. It is purely used for performance. 1752 operation much. It is purely used for performance.
1741 1753
1742 JSON and JSON::XS 1754 JSON and JSON::XS
1743 This module is required when you want to read or write JSON data via 1755 One of these modules is required when you want to read or write JSON
1744 AnyEvent::Handle. It is also written in pure-perl, but can take 1756 data via AnyEvent::Handle. It is also written in pure-perl, but can
1745 advantage of the ultra-high-speed JSON::XS module when it is 1757 take advantage of the ultra-high-speed JSON::XS module when it is
1746 installed. 1758 installed.
1747 1759
1748 In fact, AnyEvent::Handle will use JSON::XS by default if it is 1760 In fact, AnyEvent::Handle will use JSON::XS by default if it is
1749 installed. 1761 installed.
1750 1762

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines