[pypy-commit] lang-smalltalk default: Implemented Futures.
amintos
noreply at buildbot.pypy.org
Thu Apr 3 11:32:29 CEST 2014
Author: amintos
Branch:
Changeset: r759:d435cc445876
Date: 2014-01-16 23:49 +0100
http://bitbucket.org/pypy/lang-smalltalk/changeset/d435cc445876/
Log: Implemented Futures. usage: f := [41 + 1] async. ^f value
diff --git a/images/Squeak4.5-12568.changes b/images/Squeak4.5-12568.changes
--- a/images/Squeak4.5-12568.changes
+++ b/images/Squeak4.5-12568.changes
@@ -1,2 +1,2 @@
-
----STARTUP----{15 January 2014 . 2:16:33 pm} as /home/bot/lang-smalltalk/images/Squeak4.5-12568.image!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/15/2014 14:33' prior: 42646392!
benchStm
[(1 to: 1000)
do: [:t1 | SPyVM print: 'Thread 1 reporting!!']] parallelFork.
[(1 to: 1000)
do: [:t1 | SPyVM print: 'Thread 2 reporting!!']] parallelFork.
[(1 to: 1000)
do: [:t1 | SPyVM print: 'Thread 3 reporting!!']] parallelFork.
[(1 to: 1000)
do: [:t1 | SPyVM print: 'Thread 4 reporting!!']] parallelFork.
(1 to: 1000)
do: [:x | SPyVM print: '* spinlock *'].
^ 42 printString! !
----SNAPSHOT----{15 January 2014 . 2:33:47 pm} Squeak4.5-12568.image priorSource: 9103122!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/15/2014 14:35' prior: 42656801!
benchStm3
| t1 t2 |
t1 := [(1 to: 100)
do: [:t3 | SPyVM print: 'Thread 1 reporting!!']] parallelFork.
t2 := [(1 to: 100)
do: [:t3 | SPyVM print: 'Thread 2 reporting!!']] parallelFork.
SPyVM print: 'Waiting for Task 1'.
t1 wait.
SPyVM print: 'Waiting for Task 2'.
t2 wait.
SPyVM print: 'Finished waiting.'! !
----SNAPSHOT----{15 January 2014 . 2:36:01 pm} Squeak4.5-12568.image priorSource: 594!
!STMProcess methodsFor: 'as yet unclassified' stamp: 'toma 1/15/2014 14:37' prior: 42653846!
wait
<primitive: 789>
SPyVM print: ' Failed to wait for process!! '! !
----SNAPSHOT----{15 January 2014 . 2:37:09 pm} Squeak4.5-12568.image priorSource: 1091!
----STARTUP----{16 January 2014 . 9:13:20 pm} as /home/bot/lang-smalltalk/images/Squeak4.5-12568.image!
!BlockClosure methodsFor: 'scheduling' stamp: 'toma 1/16/2014 21:13' prior: 42654183!
parallelFork
^ (self newSTMProcess) fork; yourself! !
----SNAPSHOT----{16 January 2014 . 9:14:01 pm} Squeak4.5-12568.image priorSource: 1345!
!STMProcess methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 21:14'!
primWait
<primitive: 789>
SPyVM print: ' Failed to wait for process!! '! !
!STMProcess methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 21:15' prior: 33555705!
wait
SPyVM print: '[squeak] wait'
self primWait! !
!STMProcess methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 21:15' prior: 33556450!
wait
SPyVM print: '[squeak] wait'.
self primWait! !
----SNAPSHOT----{16 January 2014 . 9:15:29 pm} Squeak4.5-12568.image priorSource: 1681!
!BasicClassOrganizer methodsFor: 'accessing' stamp: 'toma 1/16/2014 22:18' prior: 17298983!
classComment
classComment
ifNil: [^ ''].
^ [classComment text ifNil: ['']] on: Error do: [^ ''].! !
Object subclass: #SPySTM
instanceVariableNames: ''
classVariableNames: ''
poolDictionaries: ''
category: 'SPy-Benchmarks'!
Object subclass: #SPySTM
instanceVariableNames: ''
classVariableNames: 'Shared'
poolDictionaries: ''
category: 'SPy-Benchmarks'!
!SPySTM class methodsFor: 'nil' stamp: 'toma 1/16/2014 22:22'!
shared
^self Shared! !
!SPySTM class methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:23' prior: 33557264!
shared
^Shared! !
!SPySTM class methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:23'!
shared: aValue
Shared := aValue! !
----SNAPSHOT----{16 January 2014 . 10:24:08 pm} Squeak4.5-12568.image priorSource: 2221!
Object subclass: #STMAtomic
instanceVariableNames: 'lock'
classVariableNames: ''
poolDictionaries: ''
category: 'Kernel-Processes'!
!STMAtomic methodsFor: 'nil' stamp: 'toma 1/16/2014 22:28'!
primEnter
<primitive: 790>! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:28' prior: 33557810!
primEnter
<primitive: 790>
SPyVM print: 'primEnter failed'.! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:28' prior: 33557933!
primEnter
<primitive: 790>
SPyVM print: 'primEnter failed'.! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:29'!
primLeave
<primitive: 791>
SPyVM print: 'primLeave failed'.! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:29'!
value
self primEnter.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:29' prior: 33558376!
value
| result |
self primEnter.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:30' prior: 33558498!
value
| result |
self primEnter.
result := self.
self primLeave
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:30' prior: 33558634!
value
| result |
self primEnter.
result := self.
self primLeave.
! !
Object subclass: #STMAtomic
instanceVariableNames: 'block'
classVariableNames: ''
poolDictionaries: ''
category: 'Kernel-Processes'!
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:31' prior: 33558803!
value
| result |
self primEnter.
result := self block value.
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:31' prior: 33559111!
value
| result error |
self primEnter.
result := self block value.
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:32' prior: 33559293!
value
| result error |
self primEnter.
[result := self block value.] on: Error do: [:err | error := err]
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:32' prior: 33559481!
value
| result error |
self primEnter.
error := nil.
[result := self block value.] on: Error do: [:err | error := err]
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:32' prior: 33559707!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Error do: [:err | error := err]
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:32' prior: 33559950!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Error do: [:err | error := err].
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:33' prior: 33560207!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Error do: [:err | error := err].
self primLeave.
error ifNotNil: [error raise]
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:33' prior: 33560465!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Exception do: [:err | error := err].
self primLeave.
error ifNotNil: [error raise]
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:35' prior: 33560754!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Exception do: [:err | error := err].
self primLeave.
error ifNotNil: [error pass]
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:35' prior: 33561047!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Exception do: [:err | error := err].
self primLeave.
error ifNotNil: [error pass]
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:35' prior: 33561339!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Exception do: [:err | error := err].
self primLeave.
error ifNotNil: [error pass].
^result
! !
!STMAtomic class methodsFor: 'nil' stamp: 'toma 1/16/2014 22:36'!
from: aBlock
^ (STMAtomic new)
block: aBlock;
yourself.! !
!STMAtomic class methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:36' prior: 33561909!
from: aBlock
^ (STMAtomic new)
block: aBlock;
yourself! !
!BlockClosure methodsFor: 'nil' stamp: 'toma 1/16/2014 22:37'!
atomic
^STMAtomic from: self! !
SystemOrganization addCategory: #'Kernel-STM'!
SystemOrganization classify: #STMAtomic under: #'Kernel-STM'!
SystemOrganization classify: #STMProcess under: #'Kernel-STM'!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:40'!
benchStmAtomic
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:40' prior: 33562476!
benchStmAtomic
| sum |
sum := 0.
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:40' prior: 33562577!
benchStmAtomic
| sum |
sum := 0.
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:40' prior: 33562700!
benchStmAtomic
| sum |
sum := 0.
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:41'!
benchStmParallel
| sum |
sum := 0.
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:41' prior: 33562933!
benchStmParallel
| sum |
sum := 0.
(1 to: self) do: [ :i |
[(1 to: 100) do: [ :k | sum := sum + k ]]
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:42' prior: 33563060!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[(1 to: 100) do: [ :k | sum := sum + k ]]
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:42' prior: 33563258!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[(i to: (i + 1000)) do: [ :k | sum := sum + k ]]
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:42' prior: 33563453!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k ]]
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:43' prior: 33563655!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k ]] parallelFork
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:43' prior: 33563872!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k. ]] parallelFork.
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:43' prior: 33564102!
benchStmParallel
| sum |
sum := 0.
(0 to: 7) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k. ]] parallelFork.
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:43' prior: 33564334!
benchStmParallel
| sum |
sum := 0.
(0 to: 7) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k. ]] parallelFork.
]
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:46' prior: 33564566!
benchStmParallel
| sum t |
sum := 0.
(0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
sum := sum + k. ]
] parallelFork
]
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:46' prior: 33564800!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
sum := sum + k. ]
] parallelFork
]
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:46' prior: 33565051!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
sum := sum + k. ]
] parallelFork
].
threads do: [:t | t wait.]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:46' prior: 33565319!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
sum := sum + k. ]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
----SNAPSHOT----{16 January 2014 . 10:47:04 pm} Squeak4.5-12568.image priorSource: 3090!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:56' prior: 33562824!
benchStmAtomic
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
[sum := sum + k. ] atomic value]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:57' prior: 33566018!
benchStmAtomic
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000 - 1)) do: [ :k |
[sum := sum + k. ] atomic value]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:57' prior: 33565614!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000 - 1)) do: [ :k |
sum := sum + k. ]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:57' prior: 33566678!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000 - 1)) do: [ :k |
sum := sum + k. ]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
----SNAPSHOT----{16 January 2014 . 10:58:17 pm} Squeak4.5-12568.image priorSource: 11414!
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 23:01' prior: 33561633!
value
| result |
self primEnter.
result := self block value.
self primLeave.
^result
! !
!STMAtomic methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:02'!
block
^ block! !
!STMAtomic methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:02'!
block: anObject
block := anObject! !
[ 1 + 1 ] atomic value!
[ 1 + 1 ] atomic value!
----SNAPSHOT----{16 January 2014 . 11:03:21 pm} Squeak4.5-12568.image priorSource: 12802!
----SNAPSHOT----{16 January 2014 . 11:03:41 pm} Squeak4.5-12568.image priorSource: 13325!
----SNAPSHOT----{16 January 2014 . 11:03:45 pm} Squeak4.5-12568.image priorSource: 13416!
\ No newline at end of file
+
----STARTUP----{15 January 2014 . 2:16:33 pm} as /home/bot/lang-smalltalk/images/Squeak4.5-12568.image!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/15/2014 14:33' prior: 42646392!
benchStm
[(1 to: 1000)
do: [:t1 | SPyVM print: 'Thread 1 reporting!!']] parallelFork.
[(1 to: 1000)
do: [:t1 | SPyVM print: 'Thread 2 reporting!!']] parallelFork.
[(1 to: 1000)
do: [:t1 | SPyVM print: 'Thread 3 reporting!!']] parallelFork.
[(1 to: 1000)
do: [:t1 | SPyVM print: 'Thread 4 reporting!!']] parallelFork.
(1 to: 1000)
do: [:x | SPyVM print: '* spinlock *'].
^ 42 printString! !
----SNAPSHOT----{15 January 2014 . 2:33:47 pm} Squeak4.5-12568.image priorSource: 9103122!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/15/2014 14:35' prior: 42656801!
benchStm3
| t1 t2 |
t1 := [(1 to: 100)
do: [:t3 | SPyVM print: 'Thread 1 reporting!!']] parallelFork.
t2 := [(1 to: 100)
do: [:t3 | SPyVM print: 'Thread 2 reporting!!']] parallelFork.
SPyVM print: 'Waiting for Task 1'.
t1 wait.
SPyVM print: 'Waiting for Task 2'.
t2 wait.
SPyVM print: 'Finished waiting.'! !
----SNAPSHOT----{15 January 2014 . 2:36:01 pm} Squeak4.5-12568.image priorSource: 594!
!STMProcess methodsFor: 'as yet unclassified' stamp: 'toma 1/15/2014 14:37' prior: 42653846!
wait
<primitive: 789>
SPyVM print: ' Failed to wait for process!! '! !
----SNAPSHOT----{15 January 2014 . 2:37:09 pm} Squeak4.5-12568.image priorSource: 1091!
----STARTUP----{16 January 2014 . 9:13:20 pm} as /home/bot/lang-smalltalk/images/Squeak4.5-12568.image!
!BlockClosure methodsFor: 'scheduling' stamp: 'toma 1/16/2014 21:13' prior: 42654183!
parallelFork
^ (self newSTMProcess) fork; yourself! !
----SNAPSHOT----{16 January 2014 . 9:14:01 pm} Squeak4.5-12568.image priorSource: 1345!
!STMProcess methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 21:14'!
primWait
<primitive: 789>
SPyVM print: ' Failed to wait for process!! '! !
!STMProcess methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 21:15' prior: 33555705!
wait
SPyVM print: '[squeak] wait'
self primWait! !
!STMProcess methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 21:15' prior: 33556450!
wait
SPyVM print: '[squeak] wait'.
self primWait! !
----SNAPSHOT----{16 January 2014 . 9:15:29 pm} Squeak4.5-12568.image priorSource: 1681!
!BasicClassOrganizer methodsFor: 'accessing' stamp: 'toma 1/16/2014 22:18' prior: 17298983!
classComment
classComment
ifNil: [^ ''].
^ [classComment text ifNil: ['']] on: Error do: [^ ''].! !
Object subclass: #SPySTM
instanceVariableNames: ''
classVariableNames: ''
poolDictionaries: ''
category: 'SPy-Benchmarks'!
Object subclass: #SPySTM
instanceVariableNames: ''
classVariableNames: 'Shared'
poolDictionaries: ''
category: 'SPy-Benchmarks'!
!SPySTM class methodsFor: 'nil' stamp: 'toma 1/16/2014 22:22'!
shared
^self Shared! !
!SPySTM class methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:23' prior: 33557264!
shared
^Shared! !
!SPySTM class methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:23'!
shared: aValue
Shared := aValue! !
----SNAPSHOT----{16 January 2014 . 10:24:08 pm} Squeak4.5-12568.image priorSource: 2221!
Object subclass: #STMAtomic
instanceVariableNames: 'lock'
classVariableNames: ''
poolDictionaries: ''
category: 'Kernel-Processes'!
!STMAtomic methodsFor: 'nil' stamp: 'toma 1/16/2014 22:28'!
primEnter
<primitive: 790>! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:28' prior: 33557810!
primEnter
<primitive: 790>
SPyVM print: 'primEnter failed'.! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:28' prior: 33557933!
primEnter
<primitive: 790>
SPyVM print: 'primEnter failed'.! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:29'!
primLeave
<primitive: 791>
SPyVM print: 'primLeave failed'.! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:29'!
value
self primEnter.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:29' prior: 33558376!
value
| result |
self primEnter.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:30' prior: 33558498!
value
| result |
self primEnter.
result := self.
self primLeave
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:30' prior: 33558634!
value
| result |
self primEnter.
result := self.
self primLeave.
! !
Object subclass: #STMAtomic
instanceVariableNames: 'block'
classVariableNames: ''
poolDictionaries: ''
category: 'Kernel-Processes'!
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:31' prior: 33558803!
value
| result |
self primEnter.
result := self block value.
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:31' prior: 33559111!
value
| result error |
self primEnter.
result := self block value.
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:32' prior: 33559293!
value
| result error |
self primEnter.
[result := self block value.] on: Error do: [:err | error := err]
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:32' prior: 33559481!
value
| result error |
self primEnter.
error := nil.
[result := self block value.] on: Error do: [:err | error := err]
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:32' prior: 33559707!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Error do: [:err | error := err]
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:32' prior: 33559950!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Error do: [:err | error := err].
self primLeave.
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:33' prior: 33560207!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Error do: [:err | error := err].
self primLeave.
error ifNotNil: [error raise]
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:33' prior: 33560465!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Exception do: [:err | error := err].
self primLeave.
error ifNotNil: [error raise]
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:35' prior: 33560754!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Exception do: [:err | error := err].
self primLeave.
error ifNotNil: [error pass]
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:35' prior: 33561047!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Exception do: [:err | error := err].
self primLeave.
error ifNotNil: [error pass]
! !
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:35' prior: 33561339!
value
| result error |
self primEnter.
error := nil.
result := nil.
[result := self block value.] on: Exception do: [:err | error := err].
self primLeave.
error ifNotNil: [error pass].
^result
! !
!STMAtomic class methodsFor: 'nil' stamp: 'toma 1/16/2014 22:36'!
from: aBlock
^ (STMAtomic new)
block: aBlock;
yourself.! !
!STMAtomic class methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 22:36' prior: 33561909!
from: aBlock
^ (STMAtomic new)
block: aBlock;
yourself! !
!BlockClosure methodsFor: 'nil' stamp: 'toma 1/16/2014 22:37'!
atomic
^STMAtomic from: self! !
SystemOrganization addCategory: #'Kernel-STM'!
SystemOrganization classify: #STMAtomic under: #'Kernel-STM'!
SystemOrganization classify: #STMProcess under: #'Kernel-STM'!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:40'!
benchStmAtomic
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:40' prior: 33562476!
benchStmAtomic
| sum |
sum := 0.
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:40' prior: 33562577!
benchStmAtomic
| sum |
sum := 0.
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:40' prior: 33562700!
benchStmAtomic
| sum |
sum := 0.
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:41'!
benchStmParallel
| sum |
sum := 0.
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:41' prior: 33562933!
benchStmParallel
| sum |
sum := 0.
(1 to: self) do: [ :i |
[(1 to: 100) do: [ :k | sum := sum + k ]]
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:42' prior: 33563060!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[(1 to: 100) do: [ :k | sum := sum + k ]]
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:42' prior: 33563258!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[(i to: (i + 1000)) do: [ :k | sum := sum + k ]]
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:42' prior: 33563453!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k ]]
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:43' prior: 33563655!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k ]] parallelFork
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:43' prior: 33563872!
benchStmParallel
| sum |
sum := 0.
(1 to: 8) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k. ]] parallelFork.
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:43' prior: 33564102!
benchStmParallel
| sum |
sum := 0.
(0 to: 7) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k. ]] parallelFork.
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:43' prior: 33564334!
benchStmParallel
| sum |
sum := 0.
(0 to: 7) do: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k | sum := sum + k. ]] parallelFork.
]
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:46' prior: 33564566!
benchStmParallel
| sum t |
sum := 0.
(0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
sum := sum + k. ]
] parallelFork
]
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:46' prior: 33564800!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
sum := sum + k. ]
] parallelFork
]
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:46' prior: 33565051!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
sum := sum + k. ]
] parallelFork
].
threads do: [:t | t wait.]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:46' prior: 33565319!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
sum := sum + k. ]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
----SNAPSHOT----{16 January 2014 . 10:47:04 pm} Squeak4.5-12568.image priorSource: 3090!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:56' prior: 33562824!
benchStmAtomic
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000)) do: [ :k |
[sum := sum + k. ] atomic value]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:57' prior: 33566018!
benchStmAtomic
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000 - 1)) do: [ :k |
[sum := sum + k. ] atomic value]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:57' prior: 33565614!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000 - 1)) do: [ :k |
sum := sum + k. ]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 22:57' prior: 33566678!
benchStmParallel
| sum threads |
sum := 0.
threads := (0 to: 7) collect: [ :i |
[((i * 1000) to: ((i + 1) * 1000 - 1)) do: [ :k |
sum := sum + k. ]
] parallelFork
].
threads do: [:t | t wait].
^ sum printString! !
----SNAPSHOT----{16 January 2014 . 10:58:17 pm} Squeak4.5-12568.image priorSource: 11414!
!STMAtomic methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 23:01' prior: 33561633!
value
| result |
self primEnter.
result := self block value.
self primLeave.
^result
! !
!STMAtomic methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:02'!
block
^ block! !
!STMAtomic methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:02'!
block: anObject
block := anObject! !
[ 1 + 1 ] atomic value!
[ 1 + 1 ] atomic value!
----SNAPSHOT----{16 January 2014 . 11:03:21 pm} Squeak4.5-12568.image priorSource: 12802!
----SNAPSHOT----{16 January 2014 . 11:03:41 pm} Squeak4.5-12568.image priorSource: 13325!
----SNAPSHOT----{16 January 2014 . 11:03:45 pm} Squeak4.5-12568.image priorSource: 13416!
BlockClosure organization addCategory: #STM!
BlockClosure organization classify: #atomic under: #STM!
!BlockClosure methodsFor: 'STM' stamp: 'toma 1/16/2014 22:37' prior: 33562201!
atomic
^STMAtomic from: self! !
BlockClosure organization classify: #newSTMProcess under: #STM!
!BlockClosure methodsFor: 'STM' stamp: '' prior: 42643259!
newSTMProcess
^ STMProcess forContext: [self value] asContext priority: Processor activePriority! !
!BlockClosure methodsFor: 'STM' stamp: '' prior: 33568373!
newSTMProcess
^ STMProcess forContext: [self value] asContext priority: Processor activePriority! !
BlockClosure organization classify: #parallelFork under: #STM!
!BlockClosure methodsFor: 'STM' stamp: 'toma 1/16/2014 21:13' prior: 33556059!
parallelFork
^ (self newSTMProcess) fork; yourself! !
Object subclass: #STMFuture
instanceVariableNames: ''
classVariableNames: ''
poolDictionaries: ''
category: 'Kernel-STM'!
Object subclass: #STMFuture
instanceVariableNames: 'block'
classVariableNames: ''
poolDictionaries: ''
category: 'Kernel-STM'!
!STMFuture methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:33'!
block
^ block! !
!STMFuture methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:33'!
block: anObject
block := anObject! !
!STMFuture methodsFor: 'nil' stamp: 'toma 1/16/2014 23:34'!
invoke
! !
Object subclass: #STMFuture
instanceVariableNames: 'block process'
classVariableNames: ''
poolDictionaries: ''
category: 'Kernel-STM'!
!STMFuture methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:34'!
process
^ process! !
!STMFuture methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:34'!
process: anObject
process := anObject! !
!STMFuture methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 23:35' prior: 33569341!
invoke
self process: (self block parallelFork)! !
!STMFuture methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 23:35'!
value
! !
Object subclass: #STMFuture
instanceVariableNames: 'block process result'
classVariableNames: ''
poolDictionaries: ''
category: 'Kernel-STM'!
!STMFuture methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:35'!
result
^ result! !
!STMFuture methodsFor: 'accessing' stamp: 'toma 1/16/2014 23:35'!
result: anObject
result := anObject! !
!STMFuture methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 23:36' prior: 33569785!
invoke
self process: ([self result: self block value] parallelFork)! !
!STMFuture methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 23:36' prior: 33569914!
value
self process wait.! !
!STMFuture methodsFor: 'as yet unclassified' stamp: 'toma 1/16/2014 23:36' prior: 33570525!
value
self process wait.
^self result! !
!STMFuture class methodsFor: 'nil' stamp: 'toma 1/16/2014 23:37'!
invoke: aBlock
^(STMFuture new)
block: aBlock;
invoke;
yourself! !
!BlockClosure methodsFor: 'STM' stamp: 'toma 1/16/2014 23:38'!
async
^STMFuture invoke: self! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 23:38'!
benchStmFuture
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 23:39' prior: 33570998!
benchStmFuture
| futures |
! !
(1 to: 100) sum!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 23:40' prior: 33571101!
benchStmFuture
| futures |
futures := (0 to: 7) collect: [ :id |
[(1 to: 1000) sum ]
]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 23:41' prior: 33571236!
benchStmFuture
| futures |
futures := (0 to: 7) collect: [ :id | [(1 to: 1000) sum] async]! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 23:41' prior: 33571416!
benchStmFuture
| futures |
futures := (0 to: 7) collect: [ :id | [(1 to: 1000) sum] async]
! !
(1 to: 100) inject: 0 into: [ :i :k | i + k]!
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 23:43' prior: 33571596!
benchStmFuture
| sum futures |
futures := (0 to: 7) collect: [ :id | [(1 to: 1000) sum] async].
sum := futures inject: 0 into: [ :s :f | s + (f value)]
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 23:44' prior: 33571825!
benchStmFuture
| sum futures |
futures := (0 to: 7) collect: [ :id | [(1 to: 1000) sum] async].
sum := futures inject: 0 into: [ :next :each | next + (each value)]
! !
!Integer methodsFor: 'benchmarks' stamp: 'toma 1/16/2014 23:44' prior: 33572069!
benchStmFuture
| sum futures |
futures := (0 to: 7) collect: [ :id | [(1 to: 1000) sum] async].
sum := futures inject: 0 into: [ :next :each | next + (each value)].
^ sum printString! !
----SNAPSHOT----{16 January 2014 . 11:45:18 pm} Squeak4.5-12568.image priorSource: 13507!
----SNAPSHOT----{16 January 2014 . 11:45:23 pm} Squeak4.5-12568.image priorSource: 18085!
----SNAPSHOT----{16 January 2014 . 11:46:35 pm} Squeak4.5-12568.image priorSource: 18176!
\ No newline at end of file
diff --git a/images/Squeak4.5-12568.image b/images/Squeak4.5-12568.image
index 52d50d90e1a3266b6a85440b56a284a4acc08984..61496f07de6c50ce9c9e38613e4ad2e0846e4c4d
GIT binary patch
[cut]
More information about the pypy-commit
mailing list