ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Coro/README
Revision: 1.16
Committed: Wed Oct 22 16:34:07 2008 UTC (15 years, 6 months ago) by root
Branch: MAIN
CVS Tags: rel-4_802, rel-4_803, rel-4_801
Changes since 1.15: +7 -8 lines
Log Message:
4.801

File Contents

# Content
1 NAME
2 Coro - coroutine process abstraction
3
4 SYNOPSIS
5 use Coro;
6
7 async {
8 # some asynchronous thread of execution
9 print "2\n";
10 cede; # yield back to main
11 print "4\n";
12 };
13 print "1\n";
14 cede; # yield to coroutine
15 print "3\n";
16 cede; # and again
17
18 # use locking
19 use Coro::Semaphore;
20 my $lock = new Coro::Semaphore;
21 my $locked;
22
23 $lock->down;
24 $locked = 1;
25 $lock->up;
26
27 DESCRIPTION
28 This module collection manages coroutines. Coroutines are similar to
29 threads but don't (in general) run in parallel at the same time even on
30 SMP machines. The specific flavor of coroutine used in this module also
31 guarantees you that it will not switch between coroutines unless
32 necessary, at easily-identified points in your program, so locking and
33 parallel access are rarely an issue, making coroutine programming much
34 safer and easier than threads programming.
35
36 Unlike a normal perl program, however, coroutines allow you to have
37 multiple running interpreters that share data, which is especially
38 useful to code pseudo-parallel processes and for event-based
39 programming, such as multiple HTTP-GET requests running concurrently.
40 See Coro::AnyEvent to learn more.
41
42 Coroutines are also useful because Perl has no support for threads (the
43 so called "threads" that perl offers are nothing more than the (bad)
44 process emulation coming from the Windows platform: On standard
45 operating systems they serve no purpose whatsoever, except by making
46 your programs slow and making them use a lot of memory. Best disable
47 them when building perl, or aks your software vendor/distributor to do
48 it for you).
49
50 In this module, coroutines are defined as "callchain + lexical variables
51 + @_ + $_ + $@ + $/ + C stack), that is, a coroutine has its own
52 callchain, its own set of lexicals and its own set of perls most
53 important global variables (see Coro::State for more configuration).
54
55 $Coro::main
56 This variable stores the coroutine object that represents the main
57 program. While you cna "ready" it and do most other things you can
58 do to coroutines, it is mainly useful to compare again
59 $Coro::current, to see whether you are running in the main program
60 or not.
61
62 $Coro::current
63 The coroutine object representing the current coroutine (the last
64 coroutine that the Coro scheduler switched to). The initial value is
65 $main (of course).
66
67 This variable is strictly *read-only*. You can take copies of the
68 value stored in it and use it as any other coroutine object, but you
69 must not otherwise modify the variable itself.
70
71 $Coro::idle
72 This variable is mainly useful to integrate Coro into event loops.
73 It is usually better to rely on Coro::AnyEvent or L"Coro::EV", as
74 this is pretty low-level functionality.
75
76 This variable stores a callback that is called whenever the
77 scheduler finds no ready coroutines to run. The default
78 implementation prints "FATAL: deadlock detected" and exits, because
79 the program has no other way to continue.
80
81 This hook is overwritten by modules such as "Coro::Timer" and
82 "Coro::AnyEvent" to wait on an external event that hopefully wake up
83 a coroutine so the scheduler can run it.
84
85 Note that the callback *must not*, under any circumstances, block
86 the current coroutine. Normally, this is achieved by having an "idle
87 coroutine" that calls the event loop and then blocks again, and then
88 readying that coroutine in the idle handler.
89
90 See Coro::Event or Coro::AnyEvent for examples of using this
91 technique.
92
93 Please note that if your callback recursively invokes perl (e.g. for
94 event handlers), then it must be prepared to be called recursively
95 itself.
96
97 SIMPLE COROUTINE CREATION
98 async { ... } [@args...]
99 Create a new coroutine and return it's coroutine object (usually
100 unused). The coroutine will be put into the ready queue, so it will
101 start running automatically on the next scheduler run.
102
103 The first argument is a codeblock/closure that should be executed in
104 the coroutine. When it returns argument returns the coroutine is
105 automatically terminated.
106
107 The remaining arguments are passed as arguments to the closure.
108
109 See the "Coro::State::new" constructor for info about the coroutine
110 environment in which coroutines are executed.
111
112 Calling "exit" in a coroutine will do the same as calling exit
113 outside the coroutine. Likewise, when the coroutine dies, the
114 program will exit, just as it would in the main program.
115
116 If you do not want that, you can provide a default "die" handler, or
117 simply avoid dieing (by use of "eval").
118
119 Example: Create a new coroutine that just prints its arguments.
120
121 async {
122 print "@_\n";
123 } 1,2,3,4;
124
125 async_pool { ... } [@args...]
126 Similar to "async", but uses a coroutine pool, so you should not
127 call terminate or join on it (although you are allowed to), and you
128 get a coroutine that might have executed other code already (which
129 can be good or bad :).
130
131 On the plus side, this function is faster than creating (and
132 destroying) a completly new coroutine, so if you need a lot of
133 generic coroutines in quick successsion, use "async_pool", not
134 "async".
135
136 The code block is executed in an "eval" context and a warning will
137 be issued in case of an exception instead of terminating the
138 program, as "async" does. As the coroutine is being reused, stuff
139 like "on_destroy" will not work in the expected way, unless you call
140 terminate or cancel, which somehow defeats the purpose of pooling
141 (but is fine in the exceptional case).
142
143 The priority will be reset to 0 after each run, tracing will be
144 disabled, the description will be reset and the default output
145 filehandle gets restored, so you can change all these. Otherwise the
146 coroutine will be re-used "as-is": most notably if you change other
147 per-coroutine global stuff such as $/ you *must needs* revert that
148 change, which is most simply done by using local as in: "local $/".
149
150 The idle pool size is limited to 8 idle coroutines (this can be
151 adjusted by changing $Coro::POOL_SIZE), but there can be as many
152 non-idle coros as required.
153
154 If you are concerned about pooled coroutines growing a lot because a
155 single "async_pool" used a lot of stackspace you can e.g.
156 "async_pool { terminate }" once per second or so to slowly replenish
157 the pool. In addition to that, when the stacks used by a handler
158 grows larger than 16kb (adjustable via $Coro::POOL_RSS) it will also
159 be destroyed.
160
161 STATIC METHODS
162 Static methods are actually functions that operate on the current
163 coroutine.
164
165 schedule
166 Calls the scheduler. The scheduler will find the next coroutine that
167 is to be run from the ready queue and switches to it. The next
168 coroutine to be run is simply the one with the highest priority that
169 is longest in its ready queue. If there is no coroutine ready, it
170 will clal the $Coro::idle hook.
171
172 Please note that the current coroutine will *not* be put into the
173 ready queue, so calling this function usually means you will never
174 be called again unless something else (e.g. an event handler) calls
175 "->ready", thus waking you up.
176
177 This makes "schedule" *the* generic method to use to block the
178 current coroutine and wait for events: first you remember the
179 current coroutine in a variable, then arrange for some callback of
180 yours to call "->ready" on that once some event happens, and last
181 you call "schedule" to put yourself to sleep. Note that a lot of
182 things can wake your coroutine up, so you need to check whether the
183 event indeed happened, e.g. by storing the status in a variable.
184
185 The canonical way to wait on external events is this:
186
187 {
188 # remember current coroutine
189 my $current = $Coro::current;
190
191 # register a hypothetical event handler
192 on_event_invoke sub {
193 # wake up sleeping coroutine
194 $current->ready;
195 undef $current;
196 };
197
198 # call schedule until event occurred.
199 # in case we are woken up for other reasons
200 # (current still defined), loop.
201 Coro::schedule while $current;
202 }
203
204 cede
205 "Cede" to other coroutines. This function puts the current coroutine
206 into the ready queue and calls "schedule", which has the effect of
207 giving up the current "timeslice" to other coroutines of the same or
208 higher priority. Once your coroutine gets its turn again it will
209 automatically be resumed.
210
211 This function is often called "yield" in other languages.
212
213 Coro::cede_notself
214 Works like cede, but is not exported by default and will cede to
215 *any* coroutine, regardless of priority. This is useful sometimes to
216 ensure progress is made.
217
218 terminate [arg...]
219 Terminates the current coroutine with the given status values (see
220 cancel).
221
222 killall
223 Kills/terminates/cancels all coroutines except the currently running
224 one. This is useful after a fork, either in the child or the parent,
225 as usually only one of them should inherit the running coroutines.
226
227 Note that while this will try to free some of the main programs
228 resources, you cannot free all of them, so if a coroutine that is
229 not the main program calls this function, there will be some
230 one-time resource leak.
231
232 COROUTINE METHODS
233 These are the methods you can call on coroutine objects (or to create
234 them).
235
236 new Coro \&sub [, @args...]
237 Create a new coroutine and return it. When the sub returns, the
238 coroutine automatically terminates as if "terminate" with the
239 returned values were called. To make the coroutine run you must
240 first put it into the ready queue by calling the ready method.
241
242 See "async" and "Coro::State::new" for additional info about the
243 coroutine environment.
244
245 $success = $coroutine->ready
246 Put the given coroutine into the end of its ready queue (there is
247 one queue for each priority) and return true. If the coroutine is
248 already in the ready queue, do nothing and return false.
249
250 This ensures that the scheduler will resume this coroutine
251 automatically once all the coroutines of higher priority and all
252 coroutines of the same priority that were put into the ready queue
253 earlier have been resumed.
254
255 $is_ready = $coroutine->is_ready
256 Return whether the coroutine is currently the ready queue or not,
257
258 $coroutine->cancel (arg...)
259 Terminates the given coroutine and makes it return the given
260 arguments as status (default: the empty list). Never returns if the
261 coroutine is the current coroutine.
262
263 $coroutine->join
264 Wait until the coroutine terminates and return any values given to
265 the "terminate" or "cancel" functions. "join" can be called
266 concurrently from multiple coroutines, and all will be resumed and
267 given the status return once the $coroutine terminates.
268
269 $coroutine->on_destroy (\&cb)
270 Registers a callback that is called when this coroutine gets
271 destroyed, but before it is joined. The callback gets passed the
272 terminate arguments, if any, and *must not* die, under any
273 circumstances.
274
275 $oldprio = $coroutine->prio ($newprio)
276 Sets (or gets, if the argument is missing) the priority of the
277 coroutine. Higher priority coroutines get run before lower priority
278 coroutines. Priorities are small signed integers (currently -4 ..
279 +3), that you can refer to using PRIO_xxx constants (use the import
280 tag :prio to get then):
281
282 PRIO_MAX > PRIO_HIGH > PRIO_NORMAL > PRIO_LOW > PRIO_IDLE > PRIO_MIN
283 3 > 1 > 0 > -1 > -3 > -4
284
285 # set priority to HIGH
286 current->prio(PRIO_HIGH);
287
288 The idle coroutine ($Coro::idle) always has a lower priority than
289 any existing coroutine.
290
291 Changing the priority of the current coroutine will take effect
292 immediately, but changing the priority of coroutines in the ready
293 queue (but not running) will only take effect after the next
294 schedule (of that coroutine). This is a bug that will be fixed in
295 some future version.
296
297 $newprio = $coroutine->nice ($change)
298 Similar to "prio", but subtract the given value from the priority
299 (i.e. higher values mean lower priority, just as in unix).
300
301 $olddesc = $coroutine->desc ($newdesc)
302 Sets (or gets in case the argument is missing) the description for
303 this coroutine. This is just a free-form string you can associate
304 with a coroutine.
305
306 This method simply sets the "$coroutine->{desc}" member to the given
307 string. You can modify this member directly if you wish.
308
309 $coroutine->throw ([$scalar])
310 If $throw is specified and defined, it will be thrown as an
311 exception inside the coroutine at the next convinient point in time
312 (usually after it gains control at the next schedule/transfer/cede).
313 Otherwise clears the exception object.
314
315 The exception object will be thrown "as is" with the specified
316 scalar in $@, i.e. if it is a string, no line number or newline will
317 be appended (unlike with "die").
318
319 This can be used as a softer means than "cancel" to ask a coroutine
320 to end itself, although there is no guarentee that the exception
321 will lead to termination, and if the exception isn't caught it might
322 well end the whole program.
323
324 GLOBAL FUNCTIONS
325 Coro::nready
326 Returns the number of coroutines that are currently in the ready
327 state, i.e. that can be switched to by calling "schedule" directory
328 or indirectly. The value 0 means that the only runnable coroutine is
329 the currently running one, so "cede" would have no effect, and
330 "schedule" would cause a deadlock unless there is an idle handler
331 that wakes up some coroutines.
332
333 my $guard = Coro::guard { ... }
334 This creates and returns a guard object. Nothing happens until the
335 object gets destroyed, in which case the codeblock given as argument
336 will be executed. This is useful to free locks or other resources in
337 case of a runtime error or when the coroutine gets canceled, as in
338 both cases the guard block will be executed. The guard object
339 supports only one method, "->cancel", which will keep the codeblock
340 from being executed.
341
342 Example: set some flag and clear it again when the coroutine gets
343 canceled or the function returns:
344
345 sub do_something {
346 my $guard = Coro::guard { $busy = 0 };
347 $busy = 1;
348
349 # do something that requires $busy to be true
350 }
351
352 unblock_sub { ... }
353 This utility function takes a BLOCK or code reference and "unblocks"
354 it, returning a new coderef. Unblocking means that calling the new
355 coderef will return immediately without blocking, returning nothing,
356 while the original code ref will be called (with parameters) from
357 within another coroutine.
358
359 The reason this function exists is that many event libraries (such
360 as the venerable Event module) are not coroutine-safe (a weaker form
361 of thread-safety). This means you must not block within event
362 callbacks, otherwise you might suffer from crashes or worse. The
363 only event library currently known that is safe to use without
364 "unblock_sub" is EV.
365
366 This function allows your callbacks to block by executing them in
367 another coroutine where it is safe to block. One example where
368 blocking is handy is when you use the Coro::AIO functions to save
369 results to disk, for example.
370
371 In short: simply use "unblock_sub { ... }" instead of "sub { ... }"
372 when creating event callbacks that want to block.
373
374 If your handler does not plan to block (e.g. simply sends a message
375 to another coroutine, or puts some other coroutine into the ready
376 queue), there is no reason to use "unblock_sub".
377
378 Note that you also need to use "unblock_sub" for any other callbacks
379 that are indirectly executed by any C-based event loop. For example,
380 when you use a module that uses AnyEvent (and you use
381 Coro::AnyEvent) and it provides callbacks that are the result of
382 some event callback, then you must not block either, or use
383 "unblock_sub".
384
385 BUGS/LIMITATIONS
386 This module is not perl-pseudo-thread-safe. You should only ever use
387 this module from the same thread (this requirement might be removed in
388 the future to allow per-thread schedulers, but Coro::State does not yet
389 allow this). I recommend disabling thread support and using processes,
390 as this is much faster and uses less memory.
391
392 SEE ALSO
393 Event-Loop integration: Coro::AnyEvent, Coro::EV, Coro::Event.
394
395 Debugging: Coro::Debug.
396
397 Support/Utility: Coro::Specific, Coro::Util.
398
399 Locking/IPC: Coro::Signal, Coro::Channel, Coro::Semaphore,
400 Coro::SemaphoreSet, Coro::RWLock.
401
402 IO/Timers: Coro::Timer, Coro::Handle, Coro::Socket, Coro::AIO.
403
404 Compatibility: Coro::LWP, Coro::BDB, Coro::Storable, Coro::Select.
405
406 XS API: Coro::MakeMaker.
407
408 Low level Configuration, Coroutine Environment: Coro::State.
409
410 AUTHOR
411 Marc Lehmann <schmorp@schmorp.de>
412 http://home.schmorp.de/
413