cloudiTasks/cloudiTasks.icl

   1 module cloudiTasks
   2
   3 import Data.Func, Data.Functor, Data.Tuple
   4 import StdEnv
   5 import iTasks
   6
   7 Start w = doTasks master w
   8
   9 master :: Task ()
  10 master
  11         = get applicationOptions
  12         >>- \eo->traceValue ("Master started on port " +++ toString eo.serverPort)
  13 //      >-| asyncTask (ExistingNode "localhost" 9099) (blockWait 5)
  14 //      >-| asyncTask "localhost" 9090 (blockWait 5)
  15 //      >-| asyncTask (PrivateNode 9099) (traceValue 5 >-| traceValue 42)
  16 //      >-| asyncTaskSpawn 9099 (return 42)
  17         >-| sleepSortPar [5,1,3,8]
  18         >&^ viewSharedInformation []
  19         @! ()
  20
  21 blockWait :: Int -> Task Int
  22 blockWait i = accWorld (sleep i)
  23 where
  24         sleep :: !Int !*e -> (!Int, !*e)
  25         sleep _ _ = code {
  26                         ccall sleep "I:I:A"
  27                 }
  28
  29 sleepSortPar :: [Int] -> Task [Int]
  30 sleepSortPar numbers = parallel
  31         [ (Embedded, \stl->
  32                     asyncTaskSpawn port (blockWait num)
  33                 >-| appendTask Embedded (\_->return num) stl
  34                 @? const NoValue)
  35         \\ num  <- numbers
  36         &  port <- [9092..9099]
  37         ] [] @? \tv->case tv of
  38                 NoValue = NoValue
  39                 (Value ts _)
  40                         # r = [v\\(_, Value v True)<-ts]
  41                         = Value r (length r == length numbers)