--- Coro/Coro.pm	2001/07/22 03:24:10	1.21
+++ Coro/Coro.pm	2001/08/11 00:37:31	1.29
@@ -16,7 +16,7 @@
     # some more async code
  }
 
- yield;
+ cede;
 
 =head1 DESCRIPTION
 
@@ -26,15 +26,9 @@
 This module is still experimental, see the BUGS section below.
 
 In this module, coroutines are defined as "callchain + lexical variables
-+ @_ + $_ + $@ + $^W), that is, a coroutine has it's own callchain, it's
-own set of lexicals and it's own set of perl's most important global
-variables.
-
-WARNING: When using this module, make sure that, at program end, no
-coroutines are still running OR just call exit before falling off the
-end. The reason for this is that some coroutine of yours might have called
-into a C function, and falling off the end of main:: results in returning
-to that C function instead if to the main C interpreter.
++ @_ + $_ + $@ + $^W + C stack), that is, a coroutine has it's own
+callchain, it's own set of lexicals and it's own set of perl's most
+important global variables.
 
 =cut
 
@@ -44,13 +38,14 @@
 
 use base Exporter;
 
-$VERSION = 0.10;
+$VERSION = 0.45;
 
-@EXPORT = qw(async yield schedule terminate current);
+@EXPORT = qw(async cede schedule terminate current);
 @EXPORT_OK = qw($current);
 
 {
    my @async;
+   my $init;
 
    # this way of handling attributes simply is NOT scalable ;()
    sub import {
@@ -62,6 +57,13 @@
          for (@_) {
             if ($_ eq "Coro") {
                push @async, $ref;
+               unless ($init++) {
+                  eval q{
+                     sub INIT {
+                        &async(pop @async) while @async;
+                     }
+                  };
+               }
             } else {
                push @attrs, $_;
             }
@@ -70,9 +72,6 @@
       };
    }
 
-   sub INIT {
-      &async(pop @async) while @async;
-   }
 }
 
 =item $main
@@ -111,6 +110,16 @@
    exit(51);
 };
 
+# this coroutine is necessary because a coroutine
+# cannot destroy itself.
+my @destroy;
+my $manager = new Coro sub {
+   while() {
+      delete ((pop @destroy)->{_coro_state}) while @destroy;
+      &schedule;
+   }
+};
+
 # we really need priorities...
 my @ready; # the ready queue. hehe, rather broken ;)
 
@@ -140,6 +149,7 @@
 
 sub async(&@) {
    my $pid = new Coro @_;
+   $manager->ready; # this ensures that the stack is cloned from the manager
    $pid->ready;
    $pid;
 }
@@ -160,14 +170,15 @@
    Coro::State::transfer($prev, $current);
 }
 
-=item yield
+=item cede
 
-Yield to other processes. This function puts the current process into the
-ready queue and calls C<schedule>.
+"Cede" to other processes. This function puts the current process into the
+ready queue and calls C<schedule>, which has the effect of giving up the
+current "timeslice" to other coroutines of the same or higher priority.
 
 =cut
 
-sub yield {
+sub cede {
    $current->ready;
    &schedule;
 }
@@ -181,9 +192,9 @@
 =cut
 
 sub terminate {
-   $current->{_results} = [@_];
-   delete $current->{_coro_state};
+   $current->cancel;
    &schedule;
+   die; # NORETURN
 }
 
 =back
@@ -228,6 +239,17 @@
    push @ready, $_[0];
 }
 
+=item $process->cancel
+
+Like C<terminate>, but terminates the specified process instead.
+
+=cut
+
+sub cancel {
+   push @destroy, $_[0];
+   $manager->ready;
+}
+
 =back
 
 =cut
@@ -251,7 +273,8 @@
 =head1 SEE ALSO
 
 L<Coro::Channel>, L<Coro::Cont>, L<Coro::Specific>, L<Coro::Semaphore>,
-L<Coro::Signal>, L<Coro::State>, L<Coro::Event>.
+L<Coro::Signal>, L<Coro::State>, L<Coro::Event>, L<Coro::RWLock>,
+L<Coro::Handle>, L<Coro::Socket>.
 
 =head1 AUTHOR