Programming with distributed functional futures

functionalFutures.fsx

open MBrace.Core

f : Cloud<Int>
g,h : int -> Cloud<Int>
j,k : int -> int -> Cloud<int>

let spawn c = Cloud.StartAsTask c
let get t = Cloud.AwaitTask t
let (>>=) c f = cloud.Bind(c, f)

let main = cloud {
         let! a = spawn f
         let! b = spawn (get a >>= g)
         let! c = spawn (get a >>= h)
         let! d = spawn (get b >>= (fun x -> get c >>= (fun y -> j x y)))
         let! e = spawn (get b >>= (fun x -> get d >>= (fun y -> k x y)))
         return! get e
}