1 USING: concurrency.combinators tools.test random kernel math
2 concurrency.mailboxes threads sequences accessors arrays
4 IN: concurrency.combinators.tests
6 [ [ drop ] parallel-each ] must-infer
7 { 2 0 } [ [ 2drop ] 2parallel-each ] must-infer-as
8 [ [ ] parallel-map ] must-infer
9 { 2 1 } [ [ 2array ] 2parallel-map ] must-infer-as
10 [ [ ] parallel-filter ] must-infer
12 [ { 1 4 9 } ] [ { 1 2 3 } [ sq ] parallel-map ] unit-test
14 [ { 1 4 9 } ] [ { 1 2 3 } [ 1000000 random sleep sq ] parallel-map ] unit-test
16 [ { 1 2 3 } [ dup 2 mod 0 = [ "Even" throw ] when ] parallel-map ]
17 [ error>> "Even" = ] must-fail-with
20 [ 10 iota [ 3 mod zero? ] parallel-filter ] unit-test
25 10 iota over [ push ] curry parallel-each
30 { 1 4 3 } { 10 5 10 } [ * ] 2parallel-map
34 { 1 4 3 } { 10 5 10 } [ - ] 2parallel-map
38 { 1 4 3 } { 1 0 1 } [ / drop ] 2parallel-each
44 10 iota 10 iota pick [ [ push ] [ push ] bi ] curry 2parallel-each
48 [ { f } [ "OOPS" throw ] parallel-each ] must-fail
52 { [ 1 - ] [ sq ] [ 1 + ] } parallel-cleave
53 [ number>string ] 3 parallel-napply
54 { [ "a" append ] [ "b" append ] [ "c" append ] } parallel-spread
57 { H{ { 0 4 } { 2 6 } { 4 8 } } } [
58 H{ { 1 2 } { 3 4 } { 5 6 } } [