steve
/
factor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

get linked processes working again

chris.double 2006-08-31 11:10:34 +00:00
parent cc41d2b3ef
commit 88cfa78fc4
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
contrib/concurrency/concurrency.factor
View File

@ -188,7 +188,6 @@ DEFER: register-process
DEFER: unregister-process DEFER: unregister-process
: (spawn) ( quot -- process ) : (spawn) ( quot -- process )
#! Start a process which runs the given quotation.
[ in-thread ] make-process [ with-process ] over slip ; [ in-thread ] make-process [ with-process ] over slip ;
: spawn ( quot -- process ) : spawn ( quot -- process )
@ -231,12 +230,15 @@ M: process send ( message process -- )
#! Rethrow the error to the linked process #! Rethrow the error to the linked process
self process-links [ over <linked-exception> swap send ] each drop ; self process-links [ over <linked-exception> swap send ] each drop ;
: (spawn-link) ( quot -- process )
[ in-thread ] self make-linked-process [ with-process ] over slip ;
: spawn-link ( quot -- process ) : spawn-link ( quot -- process )
#! Same as spawn but if the quotation throws an error that #! Same as spawn but if the quotation throws an error that
#! is uncaught, that error gets propogated to the process #! is uncaught, that error gets propogated to the process
#! performing the spawn-link. #! performing the spawn-link.
[ catch [ rethrow-linked ] when* ] curry [ catch [ rethrow-linked ] when* ] curry
[ in-thread ] self make-linked-process [ with-process ] over slip ; [ self dup process-pid swap register-process call self process-pid unregister-process ] curry (spawn-link) ;
#! A common operation is to send a message to a process containing #! A common operation is to send a message to a process containing
#! the sending process so the receiver can send a reply back. A 'tag' #! the sending process so the receiver can send a reply back. A 'tag'