http://xqerl.org/modules/actor

This module is statically bound to the prefix "actor".

Description

Module for spawning processes mid-query and asynchronous message-passing between these processes.

(: Save the address of the current actor :)
let $replyTo := actor:self()
(: Spawn 10,000 child actors and save their addresses in $children :)
let $children := (
    for $a in 1 to 10000
    (: Build a 0-arity function to spawn  :)
    let $fun := 
      function()
        {
          (: Build a nice message and send it to the actor addressed by $replyTo :)
          let $cmt := ``[From `{ $a }`: Hi, my name is `{ actor:self() }`.]``
          return
            actor:send($replyTo, $cmt)
        }
    return
      (: Spawn the actor :)
      actor:spawn($fun)
  )
return
  (: Collect the responses sent to this actor by their 'from' address
     These will be in the order sent :)
  $children ! actor:receive(.)
  (: $children ! actor:receive() would return in a possibly different order
     as the messages would be taken in the order received and not by address :)

Functions

• spawn
• self
• parent
• send
• receive