extra/concurrency/combinators/combinators.factor

   1 ! Copyright (C) 2008 Slava Pestov.\r
   2 ! See http://factorcode.org/license.txt for BSD license.\r
   3 USING: concurrency.futures concurrency.count-downs sequences\r
   4 kernel ;\r
   5 IN: concurrency.combinators\r
   6 \r
   7 : (parallel-each) ( n quot -- )\r
   8     >r <count-down> r> keep await ; inline\r
   9 \r
  10 : parallel-each ( seq quot -- )\r
  11     over length [\r
  12         [ >r curry r> spawn-stage ] 2curry each\r
  13     ] (parallel-each) ; inline\r
  14 \r
  15 : 2parallel-each ( seq1 seq2 quot -- )\r
  16     2over min-length [\r
  17         [ >r 2curry r> spawn-stage ] 2curry 2each\r
  18     ] (parallel-each) ; inline\r
  19 \r
  20 : parallel-filter ( seq quot -- newseq )\r
  21     over >r pusher >r each r> r> like ; inline\r
  22 \r
  23 : future-values dup [ ?future ] change-each ; inline\r
  24 \r
  25 : parallel-map ( seq quot -- newseq )\r
  26     [ curry future ] curry map future-values ;\r
  27     inline\r
  28 \r
  29 : 2parallel-map ( seq1 seq2 quot -- newseq )\r
  30     [ 2curry future ] curry 2map future-values ;\r