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.167 by root, Tue Jul 8 23:44:51 2008 UTC vs.
Revision 1.180 by root, Sat Sep 6 07:00:45 2008 UTC

6 6
7=head1 SYNOPSIS 7=head1 SYNOPSIS
8 8
9 use AnyEvent; 9 use AnyEvent;
10 10
11 my $w = AnyEvent->io (fh => $fh, poll => "r|w", cb => sub { 11 my $w = AnyEvent->io (fh => $fh, poll => "r|w", cb => sub { ... });
12 ...
13 });
14 12
15 my $w = AnyEvent->timer (after => $seconds, cb => sub { 13 my $w = AnyEvent->timer (after => $seconds, cb => sub { ... });
14 my $w = AnyEvent->timer (after => $seconds, interval => $seconds, cb => ...
15
16 print AnyEvent->now; # prints current event loop time
17 print AnyEvent->time; # think Time::HiRes::time or simply CORE::time.
18
19 my $w = AnyEvent->signal (signal => "TERM", cb => sub { ... });
20
21 my $w = AnyEvent->child (pid => $pid, cb => sub {
22 my ($pid, $status) = @_;
16 ... 23 ...
17 }); 24 });
18 25
19 my $w = AnyEvent->condvar; # stores whether a condition was flagged 26 my $w = AnyEvent->condvar; # stores whether a condition was flagged
20 $w->send; # wake up current and all future recv's 27 $w->send; # wake up current and all future recv's
21 $w->recv; # enters "main loop" till $condvar gets ->send 28 $w->recv; # enters "main loop" till $condvar gets ->send
29 # use a condvar in callback mode:
30 $w->cb (sub { $_[0]->recv });
22 31
23=head1 INTRODUCTION/TUTORIAL 32=head1 INTRODUCTION/TUTORIAL
24 33
25This manpage is mainly a reference manual. If you are interested 34This manpage is mainly a reference manual. If you are interested
26in a tutorial or some gentle introduction, have a look at the 35in a tutorial or some gentle introduction, have a look at the
33 42
34Executive Summary: AnyEvent is I<compatible>, AnyEvent is I<free of 43Executive Summary: AnyEvent is I<compatible>, AnyEvent is I<free of
35policy> and AnyEvent is I<small and efficient>. 44policy> and AnyEvent is I<small and efficient>.
36 45
37First and foremost, I<AnyEvent is not an event model> itself, it only 46First and foremost, I<AnyEvent is not an event model> itself, it only
38interfaces to whatever event model the main program happens to use in a 47interfaces to whatever event model the main program happens to use, in a
39pragmatic way. For event models and certain classes of immortals alike, 48pragmatic way. For event models and certain classes of immortals alike,
40the statement "there can only be one" is a bitter reality: In general, 49the statement "there can only be one" is a bitter reality: In general,
41only one event loop can be active at the same time in a process. AnyEvent 50only one event loop can be active at the same time in a process. AnyEvent
42helps hiding the differences between those event loops. 51cannot change this, but it can hide the differences between those event
52loops.
43 53
44The goal of AnyEvent is to offer module authors the ability to do event 54The goal of AnyEvent is to offer module authors the ability to do event
45programming (waiting for I/O or timer events) without subscribing to a 55programming (waiting for I/O or timer events) without subscribing to a
46religion, a way of living, and most importantly: without forcing your 56religion, a way of living, and most importantly: without forcing your
47module users into the same thing by forcing them to use the same event 57module users into the same thing by forcing them to use the same event
48model you use. 58model you use.
49 59
50For modules like POE or IO::Async (which is a total misnomer as it is 60For modules like POE or IO::Async (which is a total misnomer as it is
51actually doing all I/O I<synchronously>...), using them in your module is 61actually doing all I/O I<synchronously>...), using them in your module is
52like joining a cult: After you joined, you are dependent on them and you 62like joining a cult: After you joined, you are dependent on them and you
53cannot use anything else, as it is simply incompatible to everything that 63cannot use anything else, as they are simply incompatible to everything
54isn't itself. What's worse, all the potential users of your module are 64that isn't them. What's worse, all the potential users of your
55I<also> forced to use the same event loop you use. 65module are I<also> forced to use the same event loop you use.
56 66
57AnyEvent is different: AnyEvent + POE works fine. AnyEvent + Glib works 67AnyEvent is different: AnyEvent + POE works fine. AnyEvent + Glib works
58fine. AnyEvent + Tk works fine etc. etc. but none of these work together 68fine. AnyEvent + Tk works fine etc. etc. but none of these work together
59with the rest: POE + IO::Async? No go. Tk + Event? No go. Again: if 69with the rest: POE + IO::Async? No go. Tk + Event? No go. Again: if
60your module uses one of those, every user of your module has to use it, 70your module uses one of those, every user of your module has to use it,
61too. But if your module uses AnyEvent, it works transparently with all 71too. But if your module uses AnyEvent, it works transparently with all
62event models it supports (including stuff like POE and IO::Async, as long 72event models it supports (including stuff like IO::Async, as long as those
63as those use one of the supported event loops. It is trivial to add new 73use one of the supported event loops. It is trivial to add new event loops
64event loops to AnyEvent, too, so it is future-proof). 74to AnyEvent, too, so it is future-proof).
65 75
66In addition to being free of having to use I<the one and only true event 76In addition to being free of having to use I<the one and only true event
67model>, AnyEvent also is free of bloat and policy: with POE or similar 77model>, AnyEvent also is free of bloat and policy: with POE or similar
68modules, you get an enormous amount of code and strict rules you have to 78modules, you get an enormous amount of code and strict rules you have to
69follow. AnyEvent, on the other hand, is lean and up to the point, by only 79follow. AnyEvent, on the other hand, is lean and up to the point, by only
380The instrument to do that is called a "condition variable", so called 390The instrument to do that is called a "condition variable", so called
381because they represent a condition that must become true. 391because they represent a condition that must become true.
382 392
383Condition variables can be created by calling the C<< AnyEvent->condvar 393Condition variables can be created by calling the C<< AnyEvent->condvar
384>> method, usually without arguments. The only argument pair allowed is 394>> method, usually without arguments. The only argument pair allowed is
395
385C<cb>, which specifies a callback to be called when the condition variable 396C<cb>, which specifies a callback to be called when the condition variable
386becomes true. 397becomes true, with the condition variable as the first argument (but not
398the results).
387 399
388After creation, the condition variable is "false" until it becomes "true" 400After creation, the condition variable is "false" until it becomes "true"
389by calling the C<send> method (or calling the condition variable as if it 401by calling the C<send> method (or calling the condition variable as if it
390were a callback, read about the caveats in the description for the C<< 402were a callback, read about the caveats in the description for the C<<
391->send >> method). 403->send >> method).
447 459
448 my $done = AnyEvent->condvar; 460 my $done = AnyEvent->condvar;
449 my $delay = AnyEvent->timer (after => 5, cb => $done); 461 my $delay = AnyEvent->timer (after => 5, cb => $done);
450 $done->recv; 462 $done->recv;
451 463
464Example: Imagine an API that returns a condvar and doesn't support
465callbacks. This is how you make a synchronous call, for example from
466the main program:
467
468 use AnyEvent::CouchDB;
469
470 ...
471
472 my @info = $couchdb->info->recv;
473
474And this is how you would just ste a callback to be called whenever the
475results are available:
476
477 $couchdb->info->cb (sub {
478 my @info = $_[0]->recv;
479 });
480
452=head3 METHODS FOR PRODUCERS 481=head3 METHODS FOR PRODUCERS
453 482
454These methods should only be used by the producing side, i.e. the 483These methods should only be used by the producing side, i.e. the
455code/module that eventually sends the signal. Note that it is also 484code/module that eventually sends the signal. Note that it is also
456the producer side which creates the condvar in most cases, but it isn't 485the producer side which creates the condvar in most cases, but it isn't
589=item $bool = $cv->ready 618=item $bool = $cv->ready
590 619
591Returns true when the condition is "true", i.e. whether C<send> or 620Returns true when the condition is "true", i.e. whether C<send> or
592C<croak> have been called. 621C<croak> have been called.
593 622
594=item $cb = $cv->cb ([new callback]) 623=item $cb = $cv->cb ($cb->($cv))
595 624
596This is a mutator function that returns the callback set and optionally 625This is a mutator function that returns the callback set and optionally
597replaces it before doing so. 626replaces it before doing so.
598 627
599The callback will be called when the condition becomes "true", i.e. when 628The callback will be called when the condition becomes "true", i.e. when
821=cut 850=cut
822 851
823package AnyEvent; 852package AnyEvent;
824 853
825no warnings; 854no warnings;
826use strict; 855use strict qw(vars subs);
827 856
828use Carp; 857use Carp;
829 858
830our $VERSION = 4.2; 859our $VERSION = 4.233;
831our $MODEL; 860our $MODEL;
832 861
833our $AUTOLOAD; 862our $AUTOLOAD;
834our @ISA; 863our @ISA;
835 864
940 } 969 }
941 } 970 }
942 971
943 push @{"$MODEL\::ISA"}, "AnyEvent::Base"; 972 push @{"$MODEL\::ISA"}, "AnyEvent::Base";
944 973
945 if ($ENV{PERL_ANYEVENT_STRICT}) {
946 unshift @AnyEvent::Base::Strict::ISA, $MODEL;
947 unshift @ISA, AnyEvent::Base::Strict::
948 } else {
949 unshift @ISA, $MODEL; 974 unshift @ISA, $MODEL;
950 } 975
976 require AnyEvent::Strict if $ENV{PERL_ANYEVENT_STRICT};
951 977
952 (shift @post_detect)->() while @post_detect; 978 (shift @post_detect)->() while @post_detect;
953 } 979 }
954 980
955 $MODEL 981 $MODEL
965 991
966 my $class = shift; 992 my $class = shift;
967 $class->$func (@_); 993 $class->$func (@_);
968} 994}
969 995
996# utility function to dup a filehandle. this is used by many backends
997# to support binding more than one watcher per filehandle (they usually
998# allow only one watcher per fd, so we dup it to get a different one).
999sub _dupfh($$$$) {
1000 my ($poll, $fh, $r, $w) = @_;
1001
1002 require Fcntl;
1003
1004 # cygwin requires the fh mode to be matching, unix doesn't
1005 my ($rw, $mode) = $poll eq "r" ? ($r, "<")
1006 : $poll eq "w" ? ($w, ">")
1007 : Carp::croak "AnyEvent->io requires poll set to either 'r' or 'w'";
1008
1009 open my $fh2, "$mode&" . fileno $fh
1010 or die "cannot dup() filehandle: $!";
1011
1012 # we assume CLOEXEC is already set by perl in all important cases
1013
1014 ($fh2, $rw)
1015}
1016
970package AnyEvent::Base; 1017package AnyEvent::Base;
971 1018
972# default implementation for now and time 1019# default implementation for now and time
973 1020
974use Time::HiRes (); 1021BEGIN {
1022 if (eval "use Time::HiRes (); time (); 1") {
1023 *_time = \&Time::HiRes::time;
1024 # if (eval "use POSIX (); (POSIX::times())...
1025 } else {
1026 *_time = \&CORE::time; # epic fail
1027 }
1028}
975 1029
976sub time { Time::HiRes::time } 1030sub time { _time }
977sub now { Time::HiRes::time } 1031sub now { _time }
978 1032
979# default implementation for ->condvar 1033# default implementation for ->condvar
980 1034
981sub condvar { 1035sub condvar {
982 bless { @_ == 3 ? (_ae_cb => $_[2]) : () }, AnyEvent::CondVar:: 1036 bless { @_ == 3 ? (_ae_cb => $_[2]) : () }, AnyEvent::CondVar::
1121 1175
1122# undocumented/compatibility with pre-3.4 1176# undocumented/compatibility with pre-3.4
1123*broadcast = \&send; 1177*broadcast = \&send;
1124*wait = \&_wait; 1178*wait = \&_wait;
1125 1179
1126package AnyEvent::Base::Strict; 1180=head1 ERROR AND EXCEPTION HANDLING
1127 1181
1128use Carp qw(croak); 1182In general, AnyEvent does not do any error handling - it relies on the
1183caller to do that if required. The L<AnyEvent::Strict> module (see also
1184the C<PERL_ANYEVENT_STRICT> environment variable, below) provides strict
1185checking of all AnyEvent methods, however, which is highly useful during
1186development.
1129 1187
1130# supply checks for argument validity for many functions 1188As for exception handling (i.e. runtime errors and exceptions thrown while
1189executing a callback), this is not only highly event-loop specific, but
1190also not in any way wrapped by this module, as this is the job of the main
1191program.
1131 1192
1132sub io { 1193The pure perl event loop simply re-throws the exception (usually
1133 my $class = shift; 1194within C<< condvar->recv >>), the L<Event> and L<EV> modules call C<<
1134 my %arg = @_; 1195$Event/EV::DIED->() >>, L<Glib> uses C<< install_exception_handler >> and
1196so on.
1135 1197
1136 ref $arg{cb} 1198=head1 ENVIRONMENT VARIABLES
1137 or croak "AnyEvent->io called with illegal cb argument '$arg{cb}'";
1138 delete $arg{cb};
1139
1140 fileno $arg{fh}
1141 or croak "AnyEvent->io called with illegal fh argument '$arg{fh}'";
1142 delete $arg{fh};
1143
1144 $arg{poll} =~ /^[rw]$/
1145 or croak "AnyEvent->io called with illegal poll argument '$arg{poll}'";
1146 delete $arg{poll};
1147
1148 croak "AnyEvent->io called with unsupported parameter(s) " . join ", ", keys %arg
1149 if keys %arg;
1150 1199
1151 $class->SUPER::io (@_) 1200The following environment variables are used by this module or its
1152} 1201submodules:
1153 1202
1154sub timer { 1203=over 4
1155 my $class = shift;
1156 my %arg = @_;
1157 1204
1158 ref $arg{cb} 1205=item C<PERL_ANYEVENT_VERBOSE>
1159 or croak "AnyEvent->timer called with illegal cb argument '$arg{cb}'";
1160 delete $arg{cb};
1161
1162 exists $arg{after}
1163 or croak "AnyEvent->timer called without mandatory 'after' parameter";
1164 delete $arg{after};
1165
1166 $arg{interval} > 0 || !$arg{interval}
1167 or croak "AnyEvent->timer called with illegal interval argument '$arg{interval}'";
1168 delete $arg{interval};
1169
1170 croak "AnyEvent->timer called with unsupported parameter(s) " . join ", ", keys %arg
1171 if keys %arg;
1172 1206
1173 $class->SUPER::timer (@_) 1207By default, AnyEvent will be completely silent except in fatal
1174} 1208conditions. You can set this environment variable to make AnyEvent more
1209talkative.
1175 1210
1176sub signal { 1211When set to C<1> or higher, causes AnyEvent to warn about unexpected
1177 my $class = shift; 1212conditions, such as not being able to load the event model specified by
1178 my %arg = @_; 1213C<PERL_ANYEVENT_MODEL>.
1179 1214
1180 ref $arg{cb} 1215When set to C<2> or higher, cause AnyEvent to report to STDERR which event
1181 or croak "AnyEvent->signal called with illegal cb argument '$arg{cb}'"; 1216model it chooses.
1182 delete $arg{cb};
1183
1184 eval "require POSIX; defined &POSIX::SIG$arg{signal}"
1185 or croak "AnyEvent->signal called with illegal signal name '$arg{signal}'";
1186 delete $arg{signal};
1187
1188 croak "AnyEvent->signal called with unsupported parameter(s) " . join ", ", keys %arg
1189 if keys %arg;
1190 1217
1191 $class->SUPER::signal (@_) 1218=item C<PERL_ANYEVENT_STRICT>
1192}
1193 1219
1194sub child { 1220AnyEvent does not do much argument checking by default, as thorough
1195 my $class = shift; 1221argument checking is very costly. Setting this variable to a true value
1196 my %arg = @_; 1222will cause AnyEvent to load C<AnyEvent::Strict> and then to thoroughly
1223check the arguments passed to most method calls. If it finds any problems
1224it will croak.
1197 1225
1198 ref $arg{cb} 1226In other words, enables "strict" mode.
1199 or croak "AnyEvent->signal called with illegal cb argument '$arg{cb}'";
1200 delete $arg{cb};
1201
1202 $arg{pid} =~ /^-?\d+$/
1203 or croak "AnyEvent->signal called with illegal pid value '$arg{pid}'";
1204 delete $arg{pid};
1205
1206 croak "AnyEvent->signal called with unsupported parameter(s) " . join ", ", keys %arg
1207 if keys %arg;
1208 1227
1209 $class->SUPER::child (@_) 1228Unlike C<use strict>, it is definitely recommended ot keep it off in
1210} 1229production. Keeping C<PERL_ANYEVENT_STRICT=1> in your environment while
1230developing programs can be very useful, however.
1211 1231
1212sub condvar { 1232=item C<PERL_ANYEVENT_MODEL>
1213 my $class = shift;
1214 my %arg = @_;
1215 1233
1216 !exists $arg{cb} or ref $arg{cb} 1234This can be used to specify the event model to be used by AnyEvent, before
1217 or croak "AnyEvent->condvar called with illegal cb argument '$arg{cb}'"; 1235auto detection and -probing kicks in. It must be a string consisting
1218 delete $arg{cb}; 1236entirely of ASCII letters. The string C<AnyEvent::Impl::> gets prepended
1219 1237and the resulting module name is loaded and if the load was successful,
1220 croak "AnyEvent->condvar called with unsupported parameter(s) " . join ", ", keys %arg 1238used as event model. If it fails to load AnyEvent will proceed with
1221 if keys %arg; 1239auto detection and -probing.
1222 1240
1223 $class->SUPER::condvar (@_) 1241This functionality might change in future versions.
1224}
1225 1242
1226sub time { 1243For example, to force the pure perl model (L<AnyEvent::Impl::Perl>) you
1227 my $class = shift; 1244could start your program like this:
1228 1245
1229 @_ 1246 PERL_ANYEVENT_MODEL=Perl perl ...
1230 and croak "AnyEvent->time wrongly called with paramaters";
1231 1247
1232 $class->SUPER::time (@_) 1248=item C<PERL_ANYEVENT_PROTOCOLS>
1233}
1234 1249
1235sub now { 1250Used by both L<AnyEvent::DNS> and L<AnyEvent::Socket> to determine preferences
1236 my $class = shift; 1251for IPv4 or IPv6. The default is unspecified (and might change, or be the result
1252of auto probing).
1237 1253
1238 @_ 1254Must be set to a comma-separated list of protocols or address families,
1239 and croak "AnyEvent->now wrongly called with paramaters"; 1255current supported: C<ipv4> and C<ipv6>. Only protocols mentioned will be
1256used, and preference will be given to protocols mentioned earlier in the
1257list.
1240 1258
1241 $class->SUPER::now (@_) 1259This variable can effectively be used for denial-of-service attacks
1242} 1260against local programs (e.g. when setuid), although the impact is likely
1261small, as the program has to handle connection errors already-
1262
1263Examples: C<PERL_ANYEVENT_PROTOCOLS=ipv4,ipv6> - prefer IPv4 over IPv6,
1264but support both and try to use both. C<PERL_ANYEVENT_PROTOCOLS=ipv4>
1265- only support IPv4, never try to resolve or contact IPv6
1266addresses. C<PERL_ANYEVENT_PROTOCOLS=ipv6,ipv4> support either IPv4 or
1267IPv6, but prefer IPv6 over IPv4.
1268
1269=item C<PERL_ANYEVENT_EDNS0>
1270
1271Used by L<AnyEvent::DNS> to decide whether to use the EDNS0 extension
1272for DNS. This extension is generally useful to reduce DNS traffic, but
1273some (broken) firewalls drop such DNS packets, which is why it is off by
1274default.
1275
1276Setting this variable to C<1> will cause L<AnyEvent::DNS> to announce
1277EDNS0 in its DNS requests.
1278
1279=item C<PERL_ANYEVENT_MAX_FORKS>
1280
1281The maximum number of child processes that C<AnyEvent::Util::fork_call>
1282will create in parallel.
1283
1284=back
1243 1285
1244=head1 SUPPLYING YOUR OWN EVENT MODEL INTERFACE 1286=head1 SUPPLYING YOUR OWN EVENT MODEL INTERFACE
1245 1287
1246This is an advanced topic that you do not normally need to use AnyEvent in 1288This is an advanced topic that you do not normally need to use AnyEvent in
1247a module. This section is only of use to event loop authors who want to 1289a module. This section is only of use to event loop authors who want to
1281 1323
1282I<rxvt-unicode> also cheats a bit by not providing blocking access to 1324I<rxvt-unicode> also cheats a bit by not providing blocking access to
1283condition variables: code blocking while waiting for a condition will 1325condition variables: code blocking while waiting for a condition will
1284C<die>. This still works with most modules/usages, and blocking calls must 1326C<die>. This still works with most modules/usages, and blocking calls must
1285not be done in an interactive application, so it makes sense. 1327not be done in an interactive application, so it makes sense.
1286
1287=head1 ENVIRONMENT VARIABLES
1288
1289The following environment variables are used by this module:
1290
1291=over 4
1292
1293=item C<PERL_ANYEVENT_VERBOSE>
1294
1295By default, AnyEvent will be completely silent except in fatal
1296conditions. You can set this environment variable to make AnyEvent more
1297talkative.
1298
1299When set to C<1> or higher, causes AnyEvent to warn about unexpected
1300conditions, such as not being able to load the event model specified by
1301C<PERL_ANYEVENT_MODEL>.
1302
1303When set to C<2> or higher, cause AnyEvent to report to STDERR which event
1304model it chooses.
1305
1306=item C<PERL_ANYEVENT_STRICT>
1307
1308AnyEvent does not do much argument checking by default, as thorough
1309argument checking is very costly. Setting this variable to a true value
1310will cause AnyEvent to thoroughly check the arguments passed to most
1311method calls and croaks if it finds any problems. In other words, enables
1312"strict" mode. Unlike C<use strict> it is definitely recommended ot keep
1313it off in production.
1314
1315=item C<PERL_ANYEVENT_MODEL>
1316
1317This can be used to specify the event model to be used by AnyEvent, before
1318auto detection and -probing kicks in. It must be a string consisting
1319entirely of ASCII letters. The string C<AnyEvent::Impl::> gets prepended
1320and the resulting module name is loaded and if the load was successful,
1321used as event model. If it fails to load AnyEvent will proceed with
1322auto detection and -probing.
1323
1324This functionality might change in future versions.
1325
1326For example, to force the pure perl model (L<AnyEvent::Impl::Perl>) you
1327could start your program like this:
1328
1329 PERL_ANYEVENT_MODEL=Perl perl ...
1330
1331=item C<PERL_ANYEVENT_PROTOCOLS>
1332
1333Used by both L<AnyEvent::DNS> and L<AnyEvent::Socket> to determine preferences
1334for IPv4 or IPv6. The default is unspecified (and might change, or be the result
1335of auto probing).
1336
1337Must be set to a comma-separated list of protocols or address families,
1338current supported: C<ipv4> and C<ipv6>. Only protocols mentioned will be
1339used, and preference will be given to protocols mentioned earlier in the
1340list.
1341
1342This variable can effectively be used for denial-of-service attacks
1343against local programs (e.g. when setuid), although the impact is likely
1344small, as the program has to handle connection errors already-
1345
1346Examples: C<PERL_ANYEVENT_PROTOCOLS=ipv4,ipv6> - prefer IPv4 over IPv6,
1347but support both and try to use both. C<PERL_ANYEVENT_PROTOCOLS=ipv4>
1348- only support IPv4, never try to resolve or contact IPv6
1349addresses. C<PERL_ANYEVENT_PROTOCOLS=ipv6,ipv4> support either IPv4 or
1350IPv6, but prefer IPv6 over IPv4.
1351
1352=item C<PERL_ANYEVENT_EDNS0>
1353
1354Used by L<AnyEvent::DNS> to decide whether to use the EDNS0 extension
1355for DNS. This extension is generally useful to reduce DNS traffic, but
1356some (broken) firewalls drop such DNS packets, which is why it is off by
1357default.
1358
1359Setting this variable to C<1> will cause L<AnyEvent::DNS> to announce
1360EDNS0 in its DNS requests.
1361
1362=item C<PERL_ANYEVENT_MAX_FORKS>
1363
1364The maximum number of child processes that C<AnyEvent::Util::fork_call>
1365will create in parallel.
1366
1367=back
1368 1328
1369=head1 EXAMPLE PROGRAM 1329=head1 EXAMPLE PROGRAM
1370 1330
1371The following program uses an I/O watcher to read data from STDIN, a timer 1331The following program uses an I/O watcher to read data from STDIN, a timer
1372to display a message once per second, and a condition variable to quit the 1332to display a message once per second, and a condition variable to quit the

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines