Agent with STM

AgentStmSample.scala

package agent

import akka.agent.Agent
import akka.stm._

object AgentStmSample {

  def transfer(from: Agent[Int], to: Agent[Int], amount: Int): Boolean = {
    atomic {
      if (from.get < amount) false
      else {
        from send (_ - amount)
        to send (_ + amount)
        true
      }
    }
  }

  

  def run() {
    val from = Agent(100)
    val to = Agent(20)
    val ok = transfer(from, to, 50)
    if (ok) println("New balance, from: %s, to: %s".format(from.await, to.await))
    else println("Not enough money, transfer cancelled")

    from.close()
    to.close()
  }

  def main(args: Array[String]) {
    run()
  }



}