--- Coro/Coro.pm 2001/08/11 19:59:19 1.30 +++ Coro/Coro.pm 2001/09/24 00:16:30 1.35 @@ -38,10 +38,13 @@ use base Exporter; -$VERSION = 0.45; +$VERSION = 0.5; @EXPORT = qw(async cede schedule terminate current); -@EXPORT_OK = qw($current); +%EXPORT_TAGS = ( + prio => [qw(PRIO_MAX PRIO_HIGH PRIO_NORMAL PRIO_LOW PRIO_IDLE PRIO_MIN)], +); +@EXPORT_OK = @{$EXPORT_TAGS{prio}}; { my @async; @@ -228,6 +231,47 @@ sub cancel { push @destroy, $_[0]; $manager->ready; + &schedule if $current == $_[0]; +} + +=item $oldprio = $process->prio($newprio) + +Sets the priority of the process. Higher priority processes get run before +lower priority processes. Priorities are smalled signed integer (currently +-4 .. +3), that you can refer to using PRIO_xxx constants (use the import +tag :prio to get then): + + PRIO_MAX > PRIO_HIGH > PRIO_NORMAL > PRIO_LOW > PRIO_IDLE > PRIO_MIN + 3 > 1 > 0 > -1 > -3 > -4 + + # set priority to HIGH + current->prio(PRIO_HIGH); + +The idle coroutine ($Coro::idle) always has a lower priority than any +existing coroutine. + +Changing the priority of the current process will take effect immediately, +but changing the priority of processes in the ready queue (but not +running) will only take effect after the next schedule (of that +process). This is a bug that will be fixed in some future version. + +=cut + +sub prio { + my $old = $_[0]{prio}; + $_[0]{prio} = $_[1] if @_ > 1; + $old; +} + +=item $newprio = $process->nice($change) + +Similar to C, but subtract the given value from the priority (i.e. +higher values mean lower priority, just as in unix). + +=cut + +sub nice { + $_[0]{prio} -= $_[1]; } =back @@ -238,14 +282,8 @@ =head1 BUGS/LIMITATIONS - - could be faster, especially when the core would introduce special - support for coroutines (like it does for threads). - - there is still a memleak on coroutine termination that I could not - identify. Could be as small as a single SV. - - this module is not well-tested. - - if variables or arguments "disappear" (become undef) or become - corrupted please contact the author so he cen iron out the - remaining bugs. + - you must make very sure that no coro is still active on global destruction. + very bad things might happen otherwise (usually segfaults). - this module is not thread-safe. You must only ever use this module from the same thread (this requirement might be loosened in the future to allow per-thread schedulers, but Coro::State does not yet allow this).