"{ Package: 'stx:libjava/benchmarks' }"

JavaBenchmark subclass:#Threadring

	instanceVariableNames:''

	classVariableNames:''

	poolDictionaries:''

	category:'Benchmarks-Java-Micro'

!

Object subclass:#Thread

	instanceVariableNames:'name nextThread token semaphore done'

	classVariableNames:''

	poolDictionaries:''

	privateIn:Threadring

!

!Threadring methodsFor:'benchmarking'!

threadRing: aSemaphore

   | first last |

   503 to: 1 by: -1 do: [:i| 

      first := Thread named: i next: first done: aSemaphore.

      last isNil ifTrue: [ last := first ].

   ].

   last nextThread: first.

   ^first 

! !

!Threadring methodsFor:'running'!

runBenchmarkS:n 

    ^ 'N/A'

    "Created: / 31-10-2012 / 10:22:10 / Jan Vrany <jan.vrany@fit.cvut.cz>"

! !

!Threadring::Thread class methodsFor:'instance creation'!

named: anInteger next: aThread done: aSemaphore

   ^self new name: anInteger; nextThread: aThread; done: aSemaphore; fork 

!

new

   ^self basicNew semaphore: Semaphore new 

! !

!Threadring::Thread methodsFor:'accessing'!

done: aSemaphore

   done := aSemaphore 

!

fork

   [ self run ] fork 

!

name: anInteger

   name := anInteger 

!

nextThread: aThread

   nextThread := aThread 

!

run 

   [ self tokenNotDone ] whileTrue: [ nextThread takeToken: token - 1 ].

   done signal 

!

semaphore: aSemaphore

   semaphore := aSemaphore 

!

takeToken: x

   token := x.

   semaphore signal 

!

tokenNotDone

   semaphore wait.

   ^token > 0 

! !

!Threadring class methodsFor:'documentation'!

version_SVN

    ^ '$Id::                                                                                                                        $'

! !