Producer/Consumer with Split Counting Semaphore in Scala

prodcon.scala

import actors.Actor._

val n = 8
val front = 0
val back = 0
val buffer = new Array[Int](n)
val full = new Semaphore(0)
val empty = new Semaphore(n)

// Producer
actor {
  while (true) {
    val produced = produce()
    
    full.p()
    buffer(back) = produced
    back = (back + 1) % n
    empty.v()
  }
}.start()

// Consumer
actor {
  while (true) {
    empty.p()
    val consumed = buffer(front)
    front = (front + 1) % n
    full.v()
    
    workit(consumed)
  }
}.start()


def produce() : Int = {
  1
}

def workit(item: Int) {
  println(item)
}