scalaz actor bug

scalaz-actor-bug.scala

object ScalazActorTest extends App {
  import scalaz._
  import Scalaz._

  val running = new AtomicBoolean(false)

  object Actor {
    var count = 0
    def act() {
      val b = running.get()
      if (b) sys.error("already running!! count = " + count)
      running.set(true)
      val c = count
      count = c + 1
      running.set(false)
    }
  }

  val a = actor[Unit](e = (u: Unit) => Actor.act(), err = (t: Throwable) => {println(t); sys.exit(-1)})
  var x = 0
  while (x < 1000) {
    a ! ()
    x += 1
  }

  while(true) {
    Thread.sleep(100)
    println(Actor.count)
  }
}