"{ Package: 'exept:regressionTests' }"

TestCase subclass:#OperationInQueueTests

	instanceVariableNames:''

	classVariableNames:''

	poolDictionaries:''

	category:'Tests-Regression'

!

!OperationInQueueTests methodsFor:'tests'!

test1

    |op opQ rslt|

    opQ := OperationQueue new.

    op := [ 1 + 2 ].

    rslt := opQ scheduleOperation:op.

    self assert:(rslt == 3)

!

test2

    |op opQ rslt|

    opQ := OperationQueue new.

    op := 1.

    rslt := opQ scheduleOperation:op.

    self assert:(rslt == 1)

!

test3

    |op opQ val1 val2 val3 val1b val2b val3b 

     rslt rslt1 rslt2 rslt3 p0 p1 p2 p3 rslt1b rslt2b rslt3b p1b p2b p3b sz|

    opQ := OperationQueue new.

    opQ consumerProcessPriority:8.

    op := '1'.

    rslt := opQ scheduleOperation:op.

    self assert:(rslt = '1').

    self assert:(opQ size == 0).

    p0 := [

        opQ scheduleOperation:[ Delay waitForSeconds:1.].

    ] fork.

    p1 := [

        rslt1 := opQ scheduleOperation:(val1 := '1').

    ] fork.

    p2 := [

        rslt2 := opQ scheduleOperation:(val2 := '2').

    ] fork.

    p3 := [

        rslt3 := opQ scheduleOperation:(val3 := '3').

    ] fork.

    Delay waitForSeconds:0.2.

    self assert:((sz := opQ size) == 3).

    p1b := [

        rslt1b := opQ scheduleOperation:(val1b := '1').

    ] fork.

    p2b := [

        rslt2b := opQ scheduleOperation:(val2b := '2').

    ] fork.

    p3b := [

        rslt3b := opQ scheduleOperation:(val3b := '3').

    ] fork.

    Delay waitForSeconds:0.1.

    self assert:(opQ size == 3).

    Delay waitForSeconds:1.

    self assert:((sz := opQ size) == 0).

    self assert:(val1 == rslt1).

    self assert:(val2 == rslt2).

    self assert:(val3 == rslt3).

    self assert:(rslt1 = rslt1b).

    self assert:(rslt2 = rslt2b).

    self assert:(rslt3 = rslt3b).

    self assert:(val1b = rslt1b).

    self assert:(val2b = rslt2b).

    self assert:(val3b = rslt3b).

! !

!OperationInQueueTests class methodsFor:'documentation'!

version

    ^ '$Header$'

! !