hg/stx-libbasic2: comparison Future.st

equal deleted inserted replaced

-:7304479a2b59
+:fb363ea60a10
 For more information about the Manchester Goodies Library (from which
 this file was distributed) send e-mail:
 	To: goodies-lib@cs.man.ac.uk
 	Subject: help
 "
 "{ Package: 'stx:libbasic2' }"
 ProtoObject subclass:#Future
 	instanceVariableNames:'result semaphore'
 	classVariableNames:''
 "
 ! !
 !Future methodsFor:'evaluating'!
-block: aBlock
+block:aBlock
 "Execute aBlock in parallel with whatever called me, but
 ensure that any messages sent to me before execution
 of the block has terminated are suspended until it has terminated."
 semaphore := Semaphore new name:'Future'.
 [result := aBlock ensure:[semaphore signal]] fork
-!
+"Modified (format): / 04-10-2011 / 14:54:11 / cg"
-block: aBlock value: aValue
+!
-"Execute aBlock in parallel with whatever called me, but
-ensure that any messages sent to me before execution
+block:aBlock value:aValue
-of the block has terminated are suspended until it has terminated."
+"Execute aBlock in parallel with whatever called me, but
+ensure that any messages sent to me before execution
-semaphore := Semaphore new name:'Future'.
+of the block has terminated are suspended until it has terminated."
-[
-	result := [
+semaphore := Semaphore new name:'Future'.
-	    aBlock value:aValue
+[
-	] ensure:[semaphore signal]
+result := [
+aBlock value:aValue
+] ensure:[semaphore signal]
 ] fork
-!
+"Modified (format): / 04-10-2011 / 14:54:18 / cg"
-block: aBlock value: value1 value: value2
+!
-"Execute aBlock in parallel with whatever called me, but
-ensure that any messages sent to me before execution
+block:aBlock value:value1 value:value2
-of the block has terminated are suspended until it has terminated."
+"Execute aBlock in parallel with whatever called me, but
+ensure that any messages sent to me before execution
-semaphore := Semaphore new name:'Future'.
+of the block has terminated are suspended until it has terminated."
-[
-	result := [
+semaphore := Semaphore new name:'Future'.
-	    aBlock value: value1 value: value2
+[
-	] ensure:[semaphore signal]
+result := [
+aBlock value:value1 value:value2
+] ensure:[semaphore signal]
 ] fork
-!
+"Modified (format): / 04-10-2011 / 14:54:28 / cg"
-block: aBlock value: value1 value: value2 value: value3
+!
-"Execute aBlock in parallel with whatever called me, but
-ensure that any messages sent to me before execution
+block:aBlock value:value1 value:value2 value:value3
-of the block has terminated are suspended until it has terminated."
+"Execute aBlock in parallel with whatever called me, but
+ensure that any messages sent to me before execution
-semaphore := Semaphore new name:'Future'.
+of the block has terminated are suspended until it has terminated."
-[
-	result := [
+semaphore := Semaphore new name:'Future'.
-	    aBlock value: value1 value: value2 value: value3
+[
-	] ensure:[semaphore signal]
+result := [
+aBlock value:value1 value:value2 value:value3
+] ensure:[semaphore signal]
 ] fork
+"Modified (format): / 04-10-2011 / 14:54:45 / cg"
 !
 block: aBlock valueWithArguments: anArray
 "Execute aBlock in parallel with whatever called me, but
 ensure that any messages sent to me before execution
 [
 	result := [
 	    aBlock valueWithArguments: anArray
 	] ensure:[semaphore signal]
 ] fork
+!
+priority:prio block: aBlock
+"Execute aBlock in parallel with whatever called me, but
+ensure that any messages sent to me before execution
+of the block has terminated are suspended until it has terminated."
+semaphore := Semaphore new name:'Future'.
+[
+result := aBlock ensure:[semaphore signal]
+] forkAt:prio
+"Created: / 04-10-2011 / 14:53:21 / cg"
+!
+priority:prio block: aBlock value: aValue
+"Execute aBlock in parallel with whatever called me, but
+ensure that any messages sent to me before execution
+of the block has terminated are suspended until it has terminated."
+semaphore := Semaphore new name:'Future'.
+[
+result := [
+aBlock value:aValue
+] ensure:[semaphore signal]
+] forkAt:prio
+"Created: / 04-10-2011 / 14:53:35 / cg"
+!
+priority:prio block:aBlock value:value1 value:value2
+"Execute aBlock in parallel with whatever called me, but
+ensure that any messages sent to me before execution
+of the block has terminated are suspended until it has terminated."
+semaphore := Semaphore new name:'Future'.
+[
+result := [
+aBlock value:value1 value:value2
+] ensure:[semaphore signal]
+] forkAt:prio
+"Created: / 04-10-2011 / 14:54:03 / cg"
+!
+priority:prio block:aBlock value:value1 value:value2 value:value3
+"Execute aBlock in parallel with whatever called me, but
+ensure that any messages sent to me before execution
+of the block has terminated are suspended until it has terminated."
+semaphore := Semaphore new name:'Future'.
+[
+result := [
+aBlock value:value1 value:value2 value:value3
+] ensure:[semaphore signal]
+] forkAt:prio
+"Created: / 04-10-2011 / 14:54:51 / cg"
 ! !
 !Future methodsFor:'synchronising'!
 doesNotUnderstand:aMessage
 ! !
 !Future class methodsFor:'documentation'!
 version
-^ '$Header: /cvs/stx/stx/libbasic2/Future.st,v 1.11 2009-11-19 15:38:25 cg Exp $'
+^ '$Header: /cvs/stx/stx/libbasic2/Future.st,v 1.12 2011-10-04 12:54:58 cg Exp $'
 ! !

changeset 2666	fb363ea60a10
parent 2341	36e455705ee6
child 2667	e65a29b55fe1